Mercurial > pub > ImplabNet
comparison Implab/ActionChainTaskT.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<T> : ActionChainTaskBase, IDeferred<T> { | |
| 5 readonly Func<T, IPromise> m_task; | |
| 6 | |
| 7 public ActionChainTask(Func<T, IPromise> task, Func<Exception, IPromise> error, Func<Exception, IPromise> cancel, bool autoCancellable) : base(error,cancel, autoCancellable) { | |
| 8 m_task = task; | |
| 9 } | |
| 10 | |
| 11 public void Resolve(T value) { | |
| 12 if (m_task != null && LockCancelation()) { | |
| 13 try { | |
| 14 var p = m_task(value); | |
| 15 p.On(SetResult, HandleErrorInternal, HandleCancelInternal); | |
| 16 CancellationRequested(p.Cancel); | |
| 17 } catch (OperationCanceledException reason) { | |
| 18 HandleCancelInternal(reason); | |
| 19 } catch(Exception err) { | |
| 20 HandleErrorInternal(err); | |
| 21 } | |
| 22 } | |
| 23 } | |
| 24 | |
| 25 } | |
| 26 } | |
| 27 |
