##// 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
PromiseActionReaction`1.cs
89 lines | 3.1 KiB | text/x-csharp | CSharpLexer
/ Implab / src / PromiseActionReaction`1.cs
History | Source | Raw |Copy content |Copy permalink
cin
Added tests for Implab.ServiceHost.Unity configuration loader.
 r289 using System;
namespace Implab {
class PromiseActionReaction<T> : IResolvable<T> {
readonly Deferred m_next;
readonly IDispatcher m_dispatcher;
readonly Action<T, Deferred> m_fulfilled;
readonly Action<Exception, Deferred> m_rejected;
public IPromise Promise {
get { return m_next.Promise; }
}
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;
}
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();
}
}
void ResolveImpl (T result) {
m_fulfilled(result, m_next);
}
public void Reject(Exception error) {
cin
Fixed promise rejection when there is not specified error handler in the reaction....
 r295 if (m_rejected != null) {
cin
Added tests for Implab.ServiceHost.Unity configuration loader.
 r289 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 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
);
}
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
);
}
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
);
}
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
);
}
}
}