Mercurial > pub > ImplabNet

annotate Implab/Promise.cs @ 205:8200ab154c8a v2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Added ResetState to RunnableComponent to reset in case of failure Added StateChanged event to IRunnable Renamed Promise.SUCCESS -> Promise.Success Added Promise.FromException Renamed Bundle -> PromiseAll in PromiseExtensions
author cin
date Tue, 25 Oct 2016 17:40:33 +0300
parents 8c0b95069066
children b1e0ffdf3451
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
1 using System;
144
8c0b95069066 DRAFT: refactoring
cin
parents: 138
diff changeset
2 using Implab.Parallels;
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
3
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
4 namespace Implab {
144
8c0b95069066 DRAFT: refactoring
cin
parents: 138
diff changeset
5 public class Promise : AbstractPromise, IDeferred {
205
8200ab154c8a Added ResetState to RunnableComponent to reset in case of failure
cin
parents: 144
diff changeset
6 public static readonly IPromise Success;
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
7
144
8c0b95069066 DRAFT: refactoring
cin
parents: 138
diff changeset
8 static Promise() {
205
8200ab154c8a Added ResetState to RunnableComponent to reset in case of failure
cin
parents: 144
diff changeset
9 Success = new SuccessPromise();
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
10 }
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
11
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
12 public void Resolve() {
144
8c0b95069066 DRAFT: refactoring
cin
parents: 138
diff changeset
13 SetResult();
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
14 }
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
15
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
16 public void Reject(Exception error) {
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
17 SetError(error);
205
8200ab154c8a Added ResetState to RunnableComponent to reset in case of failure
cin
parents: 144
diff changeset
18 }
8200ab154c8a Added ResetState to RunnableComponent to reset in case of failure
cin
parents: 144
diff changeset
19
8200ab154c8a Added ResetState to RunnableComponent to reset in case of failure
cin
parents: 144
diff changeset
20 public static IPromise FromException(Exception exception) {
8200ab154c8a Added ResetState to RunnableComponent to reset in case of failure
cin
parents: 144
diff changeset
21 return new FailedPromise(exception);
8200ab154c8a Added ResetState to RunnableComponent to reset in case of failure
cin
parents: 144
diff changeset
22 }
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
23 }
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
24 }
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 112
diff changeset
25