PromiseFuncReaction`2.cs
96 lines
| 3.5 KiB
| text/x-csharp
|
CSharpLexer
cin
|
r289 | using System; | |
| using System.Diagnostics; | |||
| namespace Implab { | |||
| class PromiseFuncReaction<TIn, TRet> : IResolvable<TIn> { | |||
| readonly Deferred<TRet> m_next; | |||
| readonly IDispatcher m_dispatcher; | |||
| readonly Action<TIn, Deferred<TRet>> m_fulfilled; | |||
| readonly Action<Exception, Deferred<TRet>> m_rejected; | |||
| public IPromise<TRet> Promise { | |||
| get { return m_next.Promise; } | |||
| } | |||
| public PromiseFuncReaction(Action<TIn, Deferred<TRet>> fulfilled, Action<Exception, Deferred<TRet>> rejected, Deferred<TRet> next, IDispatcher dispatcher) { | |||
| m_next = next; | |||
| m_fulfilled = fulfilled; | |||
| m_rejected = rejected; | |||
| m_dispatcher = dispatcher; | |||
| } | |||
| public void Resolve(TIn result) { | |||
| if (m_fulfilled != null) { | |||
| if (m_dispatcher != null) | |||
| m_dispatcher.Enqueue(ResolveImpl, result); | |||
| else | |||
| ResolveImpl(result); | |||
| } else { | |||
| try { | |||
| m_next.Resolve((TRet)(object)result); | |||
| } catch(Exception error) { | |||
| // handle cast exceptions | |||
| m_next.Reject(error); | |||
| } | |||
| } | |||
| } | |||
| void ResolveImpl (TIn 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); | |||
| } | |||
| } | |||
| void RejectImpl(Exception error) { | |||
| m_rejected(error, m_next); | |||
| } | |||
| public static PromiseFuncReaction<TIn,TRet> Create(Func<TIn,TRet> fulfilled, Func<Exception, TRet> rejected, IDispatcher dispatcher) { | |||
| return new PromiseFuncReaction<TIn,TRet>( | |||
| fulfilled != null ? PromiseHandler.Create(fulfilled) : null, | |||
| rejected != null ? PromiseHandler.Create(rejected) : null, | |||
| new Deferred<TRet>(), | |||
| dispatcher | |||
| ); | |||
| } | |||
| public static PromiseFuncReaction<TIn,TRet> Create(Func<TIn,IPromise<TRet>> fulfilled, Func<Exception, TRet> rejected, IDispatcher dispatcher) { | |||
| return new PromiseFuncReaction<TIn,TRet>( | |||
| fulfilled != null ? PromiseHandler.Create(fulfilled) : null, | |||
| rejected != null ? PromiseHandler.Create(rejected) : null, | |||
| new Deferred<TRet>(), | |||
| dispatcher | |||
| ); | |||
| } | |||
| public static PromiseFuncReaction<TIn,TRet> Create(Func<TIn,TRet> fulfilled, Func<Exception, IPromise<TRet>> rejected, IDispatcher dispatcher) { | |||
| return new PromiseFuncReaction<TIn,TRet>( | |||
| fulfilled != null ? PromiseHandler.Create(fulfilled) : null, | |||
| rejected != null ? PromiseHandler.Create(rejected) : null, | |||
| new Deferred<TRet>(), | |||
| dispatcher | |||
| ); | |||
| } | |||
| public static PromiseFuncReaction<TIn,TRet> Create(Func<TIn,IPromise<TRet>> fulfilled, Func<Exception, IPromise<TRet>> rejected, IDispatcher dispatcher) { | |||
| return new PromiseFuncReaction<TIn,TRet>( | |||
| fulfilled != null ? PromiseHandler.Create(fulfilled) : null, | |||
| rejected != null ? PromiseHandler.Create(rejected) : null, | |||
| new Deferred<TRet>(), | |||
| dispatcher | |||
| ); | |||
| } | |||
| } | |||
| } |