##// END OF EJS Templates
implab » ImplabNet
RSS
Добавлена метка v3.0.14 для набора изменений 95896f882995
Добавлена метка v3.0.14 для набора изменений 95896f882995
cin - - Load All Authors

File last commit:

r289:95896f882995 v3.0.14 v3
r290:d1de82f869c9 v3
Show More
PromiseFuncReaction`1.cs
90 lines | 3.2 KiB | text/x-csharp | CSharpLexer
/ Implab / src / PromiseFuncReaction`1.cs
History | Source | Raw |Copy content |Copy permalink
cin
Added tests for Implab.ServiceHost.Unity configuration loader.
 r289 using System;
using System.Diagnostics;
namespace Implab {
class PromiseFuncReaction<TRet> : IResolvable {
readonly Deferred<TRet> m_next;
readonly IDispatcher m_dispatcher;
readonly Action<Deferred<TRet>> m_fulfilled;
readonly Action<Exception, Deferred<TRet>> m_rejected;
public IPromise<TRet> Promise {
get { return m_next.Promise; }
}
public PromiseFuncReaction(Action<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() {
if (m_fulfilled != null) {
if (m_dispatcher != null)
m_dispatcher.Enqueue(ResolveImpl);
else
ResolveImpl();
} else {
m_next.Resolve(default(TRet));
}
}
void ResolveImpl () {
m_fulfilled(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<TRet> Create(Func<TRet> fulfilled, Func<Exception, TRet> rejected, IDispatcher dispatcher) {
return new PromiseFuncReaction<TRet>(
fulfilled != null ? PromiseHandler.Create(fulfilled) : null,
rejected != null ? PromiseHandler.Create(rejected) : null,
new Deferred<TRet>(),
dispatcher
);
}
public static PromiseFuncReaction<TRet> Create(Func<IPromise<TRet>> fulfilled, Func<Exception, TRet> rejected, IDispatcher dispatcher) {
return new PromiseFuncReaction<TRet>(
fulfilled != null ? PromiseHandler.Create(fulfilled) : null,
rejected != null ? PromiseHandler.Create(rejected) : null,
new Deferred<TRet>(),
dispatcher
);
}
public static PromiseFuncReaction<TRet> Create(Func<TRet> fulfilled, Func<Exception, IPromise<TRet>> rejected, IDispatcher dispatcher) {
return new PromiseFuncReaction<TRet>(
fulfilled != null ? PromiseHandler.Create(fulfilled) : null,
rejected != null ? PromiseHandler.Create(rejected) : null,
new Deferred<TRet>(),
dispatcher
);
}
public static PromiseFuncReaction<TRet> Create(Func<IPromise<TRet>> fulfilled, Func<Exception, IPromise<TRet>> rejected, IDispatcher dispatcher) {
return new PromiseFuncReaction<TRet>(
fulfilled != null ? PromiseHandler.Create(fulfilled) : null,
rejected != null ? PromiseHandler.Create(rejected) : null,
new Deferred<TRet>(),
dispatcher
);
}
}
}