Mercurial > pub > ImplabNet

annotate Implab.Test/PromiseHelper.cs @ 203:4d9830a9bbb8 v2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Added 'Fail' method to RunnableComponent which allows component to move from Running to Failed state. Added PollingComponent a timer based runnable component More tests Added FailPromise a thin class to wrap exceptions Fixed error handling in SuccessPromise classes.
author cin
date Tue, 18 Oct 2016 17:49:54 +0300
parents eb793fbbe4ea
children d82909310094
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
1 using Implab.Parallels;
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents:
diff changeset
2 using System.Threading;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents:
diff changeset
3
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents:
diff changeset
4 namespace Implab.Test {
77
91362ffbecf8 ported tests to mono
cin
parents: 73
diff changeset
5 static class PromiseHelper {
73
3b8393be3441 fixed tests
cin
parents: 11
diff changeset
6 public static IPromise<T> Sleep<T>(int timeout, T retVal) {
149
eb793fbbe4ea fixed promises cancellation
cin
parents: 77
diff changeset
7 return AsyncPool.Invoke((ct) => {
eb793fbbe4ea fixed promises cancellation
cin
parents: 77
diff changeset
8 ct.CancellationRequested(ct.CancelOperation);
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents:
diff changeset
9 Thread.Sleep(timeout);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents:
diff changeset
10 return retVal;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents:
diff changeset
11 });
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents:
diff changeset
12 }
203
4d9830a9bbb8 Added 'Fail' method to RunnableComponent which allows component to move from
cin
parents: 149
diff changeset
13
4d9830a9bbb8 Added 'Fail' method to RunnableComponent which allows component to move from
cin
parents: 149
diff changeset
14 public static IPromise Sleep(int timeout) {
4d9830a9bbb8 Added 'Fail' method to RunnableComponent which allows component to move from
cin
parents: 149
diff changeset
15 return AsyncPool.Invoke((ct) => {
4d9830a9bbb8 Added 'Fail' method to RunnableComponent which allows component to move from
cin
parents: 149
diff changeset
16 ct.CancellationRequested(ct.CancelOperation);
4d9830a9bbb8 Added 'Fail' method to RunnableComponent which allows component to move from
cin
parents: 149
diff changeset
17 Thread.Sleep(timeout);
4d9830a9bbb8 Added 'Fail' method to RunnableComponent which allows component to move from
cin
parents: 149
diff changeset
18 return 0;
4d9830a9bbb8 Added 'Fail' method to RunnableComponent which allows component to move from
cin
parents: 149
diff changeset
19 });
4d9830a9bbb8 Added 'Fail' method to RunnableComponent which allows component to move from
cin
parents: 149
diff changeset
20 }
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents:
diff changeset
21 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents:
diff changeset
22 }