diff Implab/PromiseActionReaction.cs @ 247:fb70574741a1 v3

working on promises
author cin
date Fri, 26 Jan 2018 18:46:27 +0300
parents
children 5cb4826c2c2a
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/Implab/PromiseActionReaction.cs	Fri Jan 26 18:46:27 2018 +0300
@@ -0,0 +1,88 @@
+using System;
+using System.Diagnostics;
+
+namespace Implab {
+    class PromiseActionReaction : PromiseReaction {
+        readonly Action m_fulfilled;
+
+        readonly Action<Exception> m_rejected;
+
+        readonly Deferred m_next;
+
+        public PromiseActionReaction(Action fulfilled, Action<Exception> rejected, Deferred next, IDispatcher dispatcher) : base(dispatcher) {
+            if (fulfilled != null)
+                m_fulfilled = () => {
+                    fulfilled();
+                    next.Resolve();
+                };
+
+            if (rejected != null)
+                m_rejected = (x) => {
+                    rejected(x);
+                    next.Resolve();
+                };
+            m_next = next;
+        }
+
+        public PromiseActionReaction(Func<IPromise> fulfilled, Func<Exception, IPromise> rejected, Deferred next, IDispatcher dispatcher) : base(dispatcher) {
+            if (fulfilled != null)
+                m_fulfilled = () => { next.Resolve(fulfilled()); };
+            if (rejected != null)
+                m_rejected = (e) => { next.Resolve(rejected(e)); };
+            m_next = next;
+        }
+
+        public PromiseActionReaction(Action fulfilled, Func<Exception, IPromise> rejected, Deferred next, IDispatcher dispatcher) : base(dispatcher) {
+            if (fulfilled != null)
+                m_fulfilled = () => {
+                    fulfilled();
+                    next.Resolve();
+                };
+
+            if (rejected != null)
+                m_rejected = (e) => { next.Resolve(rejected(e)); };
+            m_next = next;
+        }
+
+        public PromiseActionReaction(Func<IPromise> fulfilled, Action<Exception> rejected, Deferred next, IDispatcher dispatcher) : base(dispatcher) {
+            if (fulfilled != null)
+                m_fulfilled = () => { next.Resolve(fulfilled()); };
+
+            if (rejected != null)
+                m_rejected = (x) => {
+                    rejected(x);
+                    next.Resolve();
+                };
+            m_next = next;
+        }
+
+
+        protected override bool HasFulfilHandler => m_fulfilled != null;
+
+        protected override bool HasRejectHandler => m_rejected != null;
+
+        protected override void DefaultReject(Exception reason) {
+            m_next.Reject(reason);
+        }
+
+        protected override void DefaultResolve() {
+            m_next.Resolve();
+        }
+
+        protected override void RejectImpl(Exception reason) {
+            try {
+                m_rejected(reason);
+            } catch (Exception e){
+                m_next.Reject(e);
+            }
+        }
+
+        protected override void ResolveImpl() {
+            try {
+                m_fulfilled();
+            } catch (Exception e){
+                m_next.Reject(e);
+            }
+        }
+    }
+}
\ No newline at end of file