Mercurial > pub > ImplabNet
comparison Implab/ActionChainTask.cs @ 192:f1da3afc3521 release v2.1
Слияние с v2
author | cin |
---|---|
date | Fri, 22 Apr 2016 13:10:34 +0300 |
parents | dd4a3590f9c6 |
children | 40d7fed4a09e |
comparison
equal
deleted
inserted
replaced
71:1714fd8678ef | 192:f1da3afc3521 |
---|---|
1 using System; | |
2 | |
3 namespace Implab { | |
4 public class ActionChainTask : ActionChainTaskBase, IDeferred { | |
5 readonly Func<IPromise> m_task; | |
6 | |
7 /// <summary> | |
8 /// Initializes a new instance of the <see cref="Implab.ActionChainTask"/> class. | |
9 /// </summary> | |
10 /// <param name="task">The operation which will be performed when the <see cref="Resolve()"/> is called.</param> | |
11 /// <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> | |
12 /// <param name="cancel">The cancellation handler.</param> | |
13 /// <param name="autoCancellable">If set to <c>true</c> will automatically accept | |
14 /// all cancel requests before the task is started with <see cref="Resolve()"/>, | |
15 /// after that all requests are directed to the task.</param> | |
16 public ActionChainTask(Func<IPromise> task, Func<Exception, IPromise> error, Func<Exception, IPromise> cancel, bool autoCancellable) : base(error,cancel, autoCancellable) { | |
17 m_task = task; | |
18 } | |
19 | |
20 public void Resolve() { | |
21 if (m_task != null && LockCancelation()) { | |
22 try { | |
23 var p = m_task(); | |
24 p.On(SetResult, HandleErrorInternal, HandleCancelInternal); | |
25 CancellationRequested(p.Cancel); | |
26 } catch (OperationCanceledException reason){ | |
27 HandleCancelInternal(reason); | |
28 } catch(Exception err) { | |
29 HandleErrorInternal(err); | |
30 } | |
31 } | |
32 } | |
33 | |
34 } | |
35 } | |
36 |