Mercurial > pub > ImplabNet
annotate Implab/ActionChainTask.cs @ 145:706fccb85524 v2
RC: cancellation support for promises + tests
| author | cin |
|---|---|
| date | Sun, 08 Mar 2015 02:52:27 +0300 |
| parents | |
| children | eb793fbbe4ea |
| rev | line source |
|---|---|
| 145 | 1 using System; |
| 2 | |
| 3 namespace Implab { | |
| 4 public class ActionChainTask : ActionChainTaskBase, IDeferred { | |
| 5 readonly Func<IPromise> m_task; | |
| 6 | |
| 7 public ActionChainTask(Func<IPromise> task, Func<Exception, IPromise> error, Func<Exception, IPromise> cancel) : base(error,cancel) { | |
| 8 m_task = task; | |
| 9 } | |
| 10 | |
| 11 public void Resolve() { | |
| 12 if (m_task != null && LockCancelation()) { | |
| 13 try { | |
| 14 Observe(m_task()); | |
| 15 } catch(Exception err) { | |
| 16 HandleErrorInternal(err); | |
| 17 } | |
| 18 } | |
| 19 } | |
| 20 | |
| 21 } | |
| 22 } | |
| 23 |