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