Mercurial > pub > ImplabNet
diff Implab/PromiseActionReaction`1.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`1.cs Fri Jan 26 18:46:27 2018 +0300 @@ -0,0 +1,87 @@ +using System; +using System.Diagnostics; + +namespace Implab { + class PromiseActionReaction<T> : PromiseReaction<T> { + readonly Action<T> m_fulfilled; + + readonly Action<Exception> m_rejected; + + readonly Deferred m_next; + + public PromiseActionReaction(Action<T> fulfilled, Action<Exception> rejected, Deferred next, IDispatcher dispatcher) : base(dispatcher) { + if (fulfilled != null) + m_fulfilled = (x) => { + fulfilled(x); + next.Resolve(); + }; + + if (rejected != null) + m_rejected = (x) => { + rejected(x); + next.Resolve(); + }; + m_next = next; + } + + public PromiseActionReaction(Func<T, IPromise> fulfilled, Func<Exception, IPromise> rejected, Deferred next, IDispatcher dispatcher) : base(dispatcher) { + if (fulfilled != null) + m_fulfilled = (x) => { next.Resolve(fulfilled(x)); }; + if (rejected != null) + m_rejected = (e) => { next.Resolve(rejected(e)); }; + m_next = next; + } + + public PromiseActionReaction(Action<T> fulfilled, Func<Exception, IPromise> rejected, Deferred next, IDispatcher dispatcher) : base(dispatcher) { + if (fulfilled != null) + m_fulfilled = (x) => { + fulfilled(x); + next.Resolve(); + }; + + if (rejected != null) + m_rejected = (e) => { next.Resolve(rejected(e)); }; + m_next = next; + } + + public PromiseActionReaction(Func<T, IPromise> fulfilled, Action<Exception> rejected, Deferred next, IDispatcher dispatcher) : base(dispatcher) { + if (fulfilled != null) + m_fulfilled = (x) => { next.Resolve(fulfilled(x)); }; + + 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(T result) { + m_next.Resolve(); + } + + protected override void RejectImpl(Exception reason) { + try { + m_rejected(reason); + } catch (Exception e) { + m_next.Reject(e); + } + } + + protected override void ResolveImpl(T result) { + try { + m_fulfilled(result); + } catch (Exception e) { + m_next.Reject(e); + } + } + } +} \ No newline at end of file