ActionChainTask.cs
36 lines
| 1.6 KiB
| text/x-csharp
|
CSharpLexer
/ Implab / ActionChainTask.cs
cin
|
r145 | using System; | ||
| namespace Implab { | ||||
| public class ActionChainTask : ActionChainTaskBase, IDeferred { | ||||
| readonly Func<IPromise> m_task; | ||||
|
cin
|
r185 | /// <summary> | ||
| /// Initializes a new instance of the <see cref="Implab.ActionChainTask"/> class. | ||||
| /// </summary> | ||||
| /// <param name="task">The operation which will be performed when the <see cref="Resolve()"/> is called.</param> | ||||
| /// <param name="error">The error handler which will invoke when the <see cref="Reject(Exception)"/> is called or when the task fails with an error.</param> | ||||
| /// <param name="cancel">The cancellation handler.</param> | ||||
| /// <param name="autoCancellable">If set to <c>true</c> will automatically accept | ||||
| /// all cancel requests before the task is started with <see cref="Resolve()"/>, | ||||
| /// after that all requests are directed to the task.</param> | ||||
|
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(); | ||
|
cin
|
r187 | p.On(SetResult, HandleErrorInternal, HandleCancelInternal); | ||
|
cin
|
r149 | CancellationRequested(p.Cancel); | ||
|
cin
|
r187 | } catch (OperationCanceledException reason){ | ||
| HandleCancelInternal(reason); | ||||
|
cin
|
r145 | } catch(Exception err) { | ||
| HandleErrorInternal(err); | ||||
| } | ||||
| } | ||||
| } | ||||
| } | ||||
| } | ||||