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 |