##// END OF EJS Templates
implab » ImplabNet
RSS
Added ResetState to RunnableComponent to reset in case of failure...
Added ResetState to RunnableComponent to reset in case of failure Added StateChanged event to IRunnable Renamed Promise.SUCCESS -> Promise.Success Added Promise.FromException Renamed Bundle -> PromiseAll in PromiseExtensions
cin - - Load All Authors

File last commit:

r196:40d7fed4a09e default
r205:8200ab154c8a v2
Show More
FuncChainTaskBase.cs
54 lines | 1.8 KiB | text/x-csharp | CSharpLexer
/ Implab / FuncChainTaskBase.cs
History | Annotation | Raw |Copy content |Copy permalink
using System;
namespace Implab {
public class FuncChainTaskBase<TResult> : AbstractTask<TResult> {
readonly Func<Exception, IPromise<TResult>> m_error;
readonly Func<Exception, IPromise<TResult>> m_cancel;
protected FuncChainTaskBase( Func<Exception, IPromise<TResult>> error, Func<Exception, IPromise<TResult>> cancel, bool autoCancellable) {
m_error = error;
m_cancel = cancel;
if (autoCancellable)
CancellationRequested(CancelOperation);
}
public void Reject(Exception error) {
if (LockCancelation())
HandleErrorInternal(error);
}
public override void CancelOperation(Exception reason) {
if (LockCancelation())
HandleCancelInternal(reason);
}
protected void HandleErrorInternal(Exception error) {
if (m_error != null) {
try {
var p = m_error(error);
p.On(SetResult, SetErrorInternal, SetCancelledInternal);
CancellationRequested(p.Cancel);
} catch(Exception err) {
SetErrorInternal(err);
}
} else {
SetErrorInternal(error);
}
}
protected void HandleCancelInternal(Exception reason) {
if (m_cancel != null) {
try {
var p = m_cancel(reason);
p.On(SetResult, HandleErrorInternal, SetCancelledInternal);
CancellationRequested(p.Cancel);
} catch (Exception err) {
SetErrorInternal(err);
}
} else {
SetCancelledInternal(reason);
}
}
}
}