PromiseActionReaction`1.cs
86 lines
| 2.8 KiB
| text/x-csharp
|
CSharpLexer
/ Implab / PromiseActionReaction`1.cs
cin
|
r247 | 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); | |||
| } | |||
| } | |||
| } | |||
| } |