##// END OF EJS Templates
implab » ImplabNet
RSS
Fixed promise rejection when there is not specified error handler in the reaction....
Fixed promise rejection when there is not specified error handler in the reaction. FIXED SPELLING IN THE XML CONTAINER CONFIGURATION signleton->singleton Code cleanup Update tests make them working on dotnet core
cin - - Load All Authors

File last commit:

r295:28af686e24f7 default
r295:28af686e24f7 default
Show More
PromiseFuncReaction`2.cs
95 lines | 3.5 KiB | text/x-csharp | CSharpLexer
/ Implab / src / PromiseFuncReaction`2.cs
History | Annotation | Raw |Copy content |Copy permalink
using System;
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_rejected != 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
);
}
}
}