PromiseActionReaction`1.cs
90 lines
| 3.1 KiB
| text/x-csharp
|
CSharpLexer
/ Implab / PromiseActionReaction`1.cs
cin
|
r247 | using System; | |
| using System.Diagnostics; | |||
| namespace Implab { | |||
|
cin
|
r249 | class PromiseActionReaction<T> : IResolvable<T> { | |
|
cin
|
r247 | readonly Deferred m_next; | |
|
cin
|
r249 | readonly IDispatcher m_dispatcher; | |
| readonly Action<T, Deferred> m_fulfilled; | |||
| readonly Action<Exception, Deferred> m_rejected; | |||
|
cin
|
r248 | public IPromise Promise { | |
| get { return m_next.Promise; } | |||
| } | |||
|
cin
|
r249 | public PromiseActionReaction(Action<T, Deferred> fulfilled, Action<Exception, Deferred> rejected, Deferred next, IDispatcher dispatcher) { | |
| m_next = next; | |||
| m_fulfilled = fulfilled; | |||
| m_rejected = rejected; | |||
| m_dispatcher = dispatcher; | |||
|
cin
|
r247 | } | |
|
cin
|
r249 | public void Resolve(T result) { | |
| if (m_fulfilled != null) { | |||
| if (m_dispatcher != null) | |||
| m_dispatcher.Enqueue(ResolveImpl, result); | |||
| else | |||
| ResolveImpl(result); | |||
| } else { | |||
| m_next.Resolve(); | |||
| } | |||
| } | |||
|
cin
|
r247 | ||
|
cin
|
r249 | void ResolveImpl (T result) { | |
| m_fulfilled(result, m_next); | |||
| } | |||
| public void Reject(Exception error) { | |||
| if (m_fulfilled != null) { | |||
| if (m_dispatcher != null) | |||
| m_dispatcher.Enqueue(RejectImpl, error); | |||
| else | |||
| RejectImpl(error); | |||
| } else { | |||
| m_next.Reject(error); | |||
| } | |||
|
cin
|
r247 | } | |
|
cin
|
r249 | void RejectImpl(Exception error) { | |
| m_rejected(error, m_next); | |||
| } | |||
|
cin
|
r247 | ||
|
cin
|
r249 | public static PromiseActionReaction<T> Create(Action<T> fulfilled, Action<Exception> rejected, IDispatcher dispatcher) { | |
| return new PromiseActionReaction<T>( | |||
| fulfilled != null ? PromiseHandler.Create(fulfilled) : null, | |||
| rejected != null ? PromiseHandler.Create(rejected) : null, | |||
| new Deferred(), | |||
| dispatcher | |||
| ); | |||
|
cin
|
r247 | } | |
|
cin
|
r249 | public static PromiseActionReaction<T> Create(Func<T,IPromise> fulfilled, Action<Exception> rejected, IDispatcher dispatcher) { | |
| return new PromiseActionReaction<T>( | |||
| fulfilled != null ? PromiseHandler.Create(fulfilled) : null, | |||
| rejected != null ? PromiseHandler.Create(rejected) : null, | |||
| new Deferred(), | |||
| dispatcher | |||
| ); | |||
|
cin
|
r248 | } | |
|
cin
|
r247 | ||
|
cin
|
r249 | public static PromiseActionReaction<T> Create(Action<T> fulfilled, Func<Exception, IPromise> rejected, IDispatcher dispatcher) { | |
| return new PromiseActionReaction<T>( | |||
| fulfilled != null ? PromiseHandler.Create(fulfilled) : null, | |||
| rejected != null ? PromiseHandler.Create(rejected) : null, | |||
| new Deferred(), | |||
| dispatcher | |||
| ); | |||
|
cin
|
r247 | } | |
|
cin
|
r249 | public static PromiseActionReaction<T> Create(Func<T,IPromise> fulfilled, Func<Exception, IPromise> rejected, IDispatcher dispatcher) { | |
| return new PromiseActionReaction<T>( | |||
| fulfilled != null ? PromiseHandler.Create(fulfilled) : null, | |||
| rejected != null ? PromiseHandler.Create(rejected) : null, | |||
| new Deferred(), | |||
| dispatcher | |||
| ); | |||
|
cin
|
r247 | } | |
| } | |||
| } |