ActionChainTaskT.cs
25 lines
| 805 B
| text/x-csharp
|
CSharpLexer
/ Implab / ActionChainTaskT.cs
cin
|
r145 | using System; | ||
namespace Implab { | ||||
public class ActionChainTask<T> : ActionChainTaskBase, IDeferred<T> { | ||||
readonly Func<T, IPromise> m_task; | ||||
cin
|
r149 | public ActionChainTask(Func<T, IPromise> task, Func<Exception, IPromise> error, Func<Exception, IPromise> cancel, bool autoCancellable) : base(error,cancel, autoCancellable) { | ||
cin
|
r145 | m_task = task; | ||
} | ||||
public void Resolve(T value) { | ||||
if (m_task != null && LockCancelation()) { | ||||
try { | ||||
cin
|
r149 | var p = m_task(value); | ||
cin
|
r187 | p.On(SetResult, HandleErrorInternal, HandleCancelInternal); | ||
cin
|
r149 | CancellationRequested(p.Cancel); | ||
cin
|
r145 | } catch(Exception err) { | ||
cin
|
r196 | SetErrorInternal(err); | ||
cin
|
r145 | } | ||
} | ||||
} | ||||
} | ||||
} | ||||