Auto status change to "Under Review"
@@ -0,0 +1,71 | |||||
|
1 | using System; | |||
|
2 | using Implab.Components; | |||
|
3 | ||||
|
4 | namespace Implab.Test.Mock { | |||
|
5 | class MockPollingComponent : PollingComponent { | |||
|
6 | public MockPollingComponent(TimeSpan interval, Func<Func<ICancellationToken, IPromise>, IPromise> dispatcher, bool initialized) : base(interval, dispatcher, initialized) { | |||
|
7 | } | |||
|
8 | ||||
|
9 | public Action MockInit { | |||
|
10 | get; | |||
|
11 | set; | |||
|
12 | } | |||
|
13 | ||||
|
14 | public Action<Exception> MockOnError { | |||
|
15 | get; | |||
|
16 | set; | |||
|
17 | } | |||
|
18 | ||||
|
19 | public Action<Exception> MockOnCancel { | |||
|
20 | get; | |||
|
21 | set; | |||
|
22 | } | |||
|
23 | ||||
|
24 | public Func<IPromise> MockStart { | |||
|
25 | get; | |||
|
26 | set; | |||
|
27 | } | |||
|
28 | ||||
|
29 | public Func<IPromise> MockStop { | |||
|
30 | get; | |||
|
31 | set; | |||
|
32 | } | |||
|
33 | ||||
|
34 | public Func<ICancellationToken, IPromise> MockTick { | |||
|
35 | get; | |||
|
36 | set; | |||
|
37 | } | |||
|
38 | ||||
|
39 | protected override IPromise OnStart() { | |||
|
40 | return MockStart != null ? Safe.Run(MockStart).Chain(base.OnStart) : Safe.Run(base.OnStart); | |||
|
41 | } | |||
|
42 | ||||
|
43 | protected override IPromise OnStop() { | |||
|
44 | return MockStop != null ? Safe.Run(MockStop).Chain(base.OnStop) : Safe.Run(base.OnStop); | |||
|
45 | } | |||
|
46 | ||||
|
47 | protected override void OnInitialize() { | |||
|
48 | if (MockInit != null) | |||
|
49 | MockInit(); | |||
|
50 | } | |||
|
51 | ||||
|
52 | protected override IPromise OnTick(ICancellationToken cancellationToken) { | |||
|
53 | return MockTick != null ? Safe.Run(() => MockTick(cancellationToken)) : Promise.SUCCESS; | |||
|
54 | } | |||
|
55 | ||||
|
56 | protected override void OnTickCancel(Exception error) { | |||
|
57 | if (MockOnCancel != null) | |||
|
58 | MockOnCancel(error); | |||
|
59 | } | |||
|
60 | ||||
|
61 | protected override void OnTickError(Exception error) { | |||
|
62 | if (MockOnError != null) | |||
|
63 | MockOnError(error); | |||
|
64 | } | |||
|
65 | ||||
|
66 | public void CallComponentFail(Exception error) { | |||
|
67 | Fail(error); | |||
|
68 | } | |||
|
69 | } | |||
|
70 | } | |||
|
71 |
@@ -0,0 +1,38 | |||||
|
1 | using System; | |||
|
2 | using Implab.Components; | |||
|
3 | ||||
|
4 | namespace Implab.Test.Mock { | |||
|
5 | class MockRunnableComponent : RunnableComponent { | |||
|
6 | public MockRunnableComponent(bool initialized) : base(initialized) { | |||
|
7 | } | |||
|
8 | ||||
|
9 | public Action MockInit { | |||
|
10 | get; | |||
|
11 | set; | |||
|
12 | } | |||
|
13 | ||||
|
14 | public Func<IPromise> MockStart { | |||
|
15 | get; | |||
|
16 | set; | |||
|
17 | } | |||
|
18 | ||||
|
19 | public Func<IPromise> MockStop { | |||
|
20 | get; | |||
|
21 | set; | |||
|
22 | } | |||
|
23 | ||||
|
24 | protected override IPromise OnStart() { | |||
|
25 | return MockStart != null ? Safe.Run(MockStart).Chain(base.OnStart) : Safe.Run(base.OnStart); | |||
|
26 | } | |||
|
27 | ||||
|
28 | protected override IPromise OnStop() { | |||
|
29 | return MockStop != null ? Safe.Run(MockStop).Chain(base.OnStop) : Safe.Run(base.OnStop); | |||
|
30 | } | |||
|
31 | ||||
|
32 | protected override void OnInitialize() { | |||
|
33 | if (MockInit != null) | |||
|
34 | MockInit(); | |||
|
35 | } | |||
|
36 | } | |||
|
37 | } | |||
|
38 |
@@ -0,0 +1,230 | |||||
|
1 | using System; | |||
|
2 | using System.Reflection; | |||
|
3 | using System.Threading; | |||
|
4 | using Implab.Parallels; | |||
|
5 | using Implab.Components; | |||
|
6 | using Implab.Test.Mock; | |||
|
7 | ||||
|
8 | #if MONO | |||
|
9 | ||||
|
10 | using NUnit.Framework; | |||
|
11 | using TestClassAttribute = NUnit.Framework.TestFixtureAttribute; | |||
|
12 | using TestMethodAttribute = NUnit.Framework.TestAttribute; | |||
|
13 | using AssertFailedException = NUnit.Framework.AssertionException; | |||
|
14 | #else | |||
|
15 | ||||
|
16 | using Microsoft.VisualStudio.TestTools.UnitTesting; | |||
|
17 | ||||
|
18 | #endif | |||
|
19 | ||||
|
20 | namespace Implab.Test { | |||
|
21 | [TestClass] | |||
|
22 | public class PollingComponentTests { | |||
|
23 | static void ShouldThrow(Action action) { | |||
|
24 | try { | |||
|
25 | action(); | |||
|
26 | Assert.Fail(); | |||
|
27 | } catch (AssertFailedException) { | |||
|
28 | throw; | |||
|
29 | } catch { | |||
|
30 | } | |||
|
31 | } | |||
|
32 | ||||
|
33 | [TestMethod] | |||
|
34 | public void NormalFlowTest() { | |||
|
35 | var comp = new MockPollingComponent(TimeSpan.FromMilliseconds(1), null, false); | |||
|
36 | ||||
|
37 | Assert.AreEqual(ExecutionState.Created, comp.State); | |||
|
38 | ||||
|
39 | comp.Init(); | |||
|
40 | ||||
|
41 | Assert.AreEqual(ExecutionState.Ready, comp.State); | |||
|
42 | ||||
|
43 | comp.Start().Join(1000); | |||
|
44 | ||||
|
45 | Assert.AreEqual(ExecutionState.Running, comp.State); | |||
|
46 | ||||
|
47 | comp.Stop().Join(1000); | |||
|
48 | ||||
|
49 | Assert.AreEqual(ExecutionState.Disposed, comp.State); | |||
|
50 | ||||
|
51 | } | |||
|
52 | ||||
|
53 | [TestMethod] | |||
|
54 | public void ShouldStartTicks() { | |||
|
55 | var signal = new Signal(); | |||
|
56 | ||||
|
57 | var comp = new MockPollingComponent(TimeSpan.FromMilliseconds(1), null, true); | |||
|
58 | comp.MockTick = ct => { | |||
|
59 | signal.Set(); | |||
|
60 | return Promise.SUCCESS; | |||
|
61 | }; | |||
|
62 | ||||
|
63 | comp.Start().Join(1000); | |||
|
64 | signal.Wait(1000); | |||
|
65 | comp.Stop().Join(1000); | |||
|
66 | } | |||
|
67 | ||||
|
68 | [TestMethod] | |||
|
69 | public void StopShouldWaitForTickToComplete() { | |||
|
70 | var comp = new MockPollingComponent(TimeSpan.FromMilliseconds(1), null, true); | |||
|
71 | var signal = new Signal(); | |||
|
72 | var promise = new Promise(); | |||
|
73 | ||||
|
74 | // timer should tick once | |||
|
75 | comp.MockTick = ct => { | |||
|
76 | signal.Set(); | |||
|
77 | return promise; | |||
|
78 | }; | |||
|
79 | ||||
|
80 | // start timer | |||
|
81 | comp.Start().Join(1000); | |||
|
82 | ||||
|
83 | signal.Wait(); // wait for tick | |||
|
84 | ||||
|
85 | // try to stop component | |||
|
86 | var stopping = comp.Stop(); | |||
|
87 | ||||
|
88 | Assert.AreEqual(ExecutionState.Stopping, comp.State); | |||
|
89 | ShouldThrow(() => stopping.Join(100)); | |||
|
90 | Assert.AreEqual(ExecutionState.Stopping, comp.State); | |||
|
91 | ||||
|
92 | // complete operation | |||
|
93 | promise.Resolve(); | |||
|
94 | ||||
|
95 | // the component should stop normally | |||
|
96 | stopping.Join(1000); | |||
|
97 | ||||
|
98 | Assert.AreEqual(ExecutionState.Disposed, comp.State); | |||
|
99 | } | |||
|
100 | ||||
|
101 | [TestMethod] | |||
|
102 | public void ShouldRecoverAfterTickError() { | |||
|
103 | var ticks = 0; | |||
|
104 | ||||
|
105 | var comp = new MockPollingComponent(TimeSpan.FromMilliseconds(1), null, true); | |||
|
106 | var signal = new Signal(); // will signal when timer fires 10 times | |||
|
107 | ||||
|
108 | comp.MockTick = ct => { | |||
|
109 | ticks++; | |||
|
110 | if (ticks == 10) | |||
|
111 | signal.Set(); | |||
|
112 | // each time handler dies | |||
|
113 | throw new Exception("tainted handler"); | |||
|
114 | }; | |||
|
115 | ||||
|
116 | comp.Start(); | |||
|
117 | ||||
|
118 | signal.Wait(1000); | |||
|
119 | ||||
|
120 | comp.Stop().Join(1000); | |||
|
121 | ||||
|
122 | Assert.AreEqual(ExecutionState.Disposed, comp.State); | |||
|
123 | } | |||
|
124 | ||||
|
125 | [TestMethod] | |||
|
126 | public void StopCancelHandlerOnStop() { | |||
|
127 | var comp = new MockPollingComponent(TimeSpan.FromMilliseconds(1), null, true); | |||
|
128 | var started = new Signal(); | |||
|
129 | bool cancelled = false; | |||
|
130 | ||||
|
131 | // timer should tick once | |||
|
132 | comp.MockTick = ct => { | |||
|
133 | started.Set(); | |||
|
134 | ||||
|
135 | while(!ct.IsCancellationRequested) { | |||
|
136 | Thread.Sleep(1); | |||
|
137 | } | |||
|
138 | ||||
|
139 | cancelled = true; | |||
|
140 | ||||
|
141 | throw new OperationCanceledException(); | |||
|
142 | }; | |||
|
143 | ||||
|
144 | // start timer | |||
|
145 | comp.Start().Join(1000); | |||
|
146 | ||||
|
147 | started.Wait(); // wait for tick | |||
|
148 | ||||
|
149 | // try to stop component | |||
|
150 | comp.Stop().Join(1000); | |||
|
151 | ||||
|
152 | Assert.AreEqual(true, cancelled); | |||
|
153 | ||||
|
154 | Assert.AreEqual(ExecutionState.Disposed, comp.State); | |||
|
155 | } | |||
|
156 | ||||
|
157 | [TestMethod] | |||
|
158 | public void FailTickOnStopShouldBeIgnored() { | |||
|
159 | var comp = new MockPollingComponent(TimeSpan.FromMilliseconds(1), null, true); | |||
|
160 | var started = new Signal(); | |||
|
161 | var finish = new Signal(); | |||
|
162 | ||||
|
163 | // timer should tick once | |||
|
164 | comp.MockTick = ct => { | |||
|
165 | started.Set(); | |||
|
166 | finish.Wait(); | |||
|
167 | // component is in stopping state here | |||
|
168 | throw new Exception("Die, die, die!!!"); | |||
|
169 | }; | |||
|
170 | ||||
|
171 | ||||
|
172 | comp.MockOnError = comp.CallComponentFail; | |||
|
173 | ||||
|
174 | // start timer | |||
|
175 | comp.Start().Join(1000); | |||
|
176 | ||||
|
177 | started.Wait(); // wait for tick | |||
|
178 | ||||
|
179 | // try to stop component | |||
|
180 | var stopping = comp.Stop(); | |||
|
181 | ||||
|
182 | // the component is in stopping state but it is waiting for the tick handler to complete | |||
|
183 | finish.Set(); // signal the tick handler to finish | |||
|
184 | ||||
|
185 | // tick handler should stop rather soon | |||
|
186 | stopping.Join(1000); | |||
|
187 | ||||
|
188 | // validate the component is disposed | |||
|
189 | Assert.AreEqual(ExecutionState.Disposed, comp.State); | |||
|
190 | } | |||
|
191 | ||||
|
192 | [TestMethod] | |||
|
193 | public void FailTickShouldFailComponent() { | |||
|
194 | var comp = new MockPollingComponent(TimeSpan.FromMilliseconds(1), null, true); | |||
|
195 | var started = new Signal(); | |||
|
196 | var finish = new Signal(); | |||
|
197 | ||||
|
198 | // timer should tick once | |||
|
199 | comp.MockTick = ct => { | |||
|
200 | started.Set(); | |||
|
201 | throw new Exception("Die, die, die!!!"); | |||
|
202 | }; | |||
|
203 | ||||
|
204 | ||||
|
205 | comp.MockOnError = err => { | |||
|
206 | comp.CallComponentFail(err); | |||
|
207 | finish.Set(); | |||
|
208 | }; | |||
|
209 | ||||
|
210 | // start timer | |||
|
211 | comp.Start().Join(1000); | |||
|
212 | ||||
|
213 | started.Wait(); // wait for tick | |||
|
214 | ||||
|
215 | finish.Wait(); | |||
|
216 | ||||
|
217 | // try to stop component | |||
|
218 | ShouldThrow(() => comp.Stop()); | |||
|
219 | ||||
|
220 | Assert.AreEqual(ExecutionState.Failed, comp.State); | |||
|
221 | Assert.IsNotNull(comp.LastError); | |||
|
222 | Assert.AreEqual("Die, die, die!!!", comp.LastError.Message); | |||
|
223 | ||||
|
224 | comp.Dispose(); | |||
|
225 | Assert.AreEqual(ExecutionState.Disposed, comp.State); | |||
|
226 | } | |||
|
227 | ||||
|
228 | } | |||
|
229 | } | |||
|
230 |
@@ -0,0 +1,155 | |||||
|
1 | using System; | |||
|
2 | using System.Threading; | |||
|
3 | using Implab.Diagnostics; | |||
|
4 | ||||
|
5 | namespace Implab.Components { | |||
|
6 | public class PollingComponent : RunnableComponent { | |||
|
7 | readonly Timer m_timer; | |||
|
8 | readonly Func<Func<ICancellationToken, IPromise>, IPromise> m_dispatcher; | |||
|
9 | readonly TimeSpan m_interval; | |||
|
10 | ||||
|
11 | readonly object m_lock = new object(); | |||
|
12 | ||||
|
13 | ActionTask m_pending; | |||
|
14 | ||||
|
15 | protected PollingComponent(TimeSpan interval, Func<Func<ICancellationToken, IPromise>, IPromise> dispatcher, bool initialized) : base(initialized) { | |||
|
16 | m_timer = new Timer(OnInternalTick); | |||
|
17 | ||||
|
18 | m_interval = interval; | |||
|
19 | m_dispatcher = dispatcher; | |||
|
20 | } | |||
|
21 | ||||
|
22 | protected override IPromise OnStart() { | |||
|
23 | m_timer.Change(TimeSpan.Zero, m_interval); | |||
|
24 | ||||
|
25 | return base.OnStart(); | |||
|
26 | } | |||
|
27 | ||||
|
28 | void OnInternalTick(object state) { | |||
|
29 | if (StartTick()) { | |||
|
30 | try { | |||
|
31 | if (m_dispatcher != null) { | |||
|
32 | var result = m_dispatcher(OnTick); | |||
|
33 | m_pending.CancellationRequested(result.Cancel); | |||
|
34 | AwaitTick(result); | |||
|
35 | } else { | |||
|
36 | AwaitTick(OnTick(m_pending)); | |||
|
37 | } | |||
|
38 | } catch (Exception error) { | |||
|
39 | HandleTickError(error); | |||
|
40 | } | |||
|
41 | } | |||
|
42 | } | |||
|
43 | ||||
|
44 | /// <summary> | |||
|
45 | /// Checks wheather there is no running handler in the component and marks that the handler is starting. | |||
|
46 | /// </summary> | |||
|
47 | /// <returns>boolean value, true - the new tick handler may be invoked, false - a tick handler is already running or a component isn't running.</returns> | |||
|
48 | /// <remarks> | |||
|
49 | /// If the component is stopping no new handlers can be run. Every successful call to this method must be completed with either AwaitTick or HandleTickError handlers. | |||
|
50 | /// </remarks> | |||
|
51 | protected virtual bool StartTick() { | |||
|
52 | lock (m_lock) { | |||
|
53 | if (State != ExecutionState.Running || m_pending != null) | |||
|
54 | return false; | |||
|
55 | // actually the component may be in a not running state here (stopping, disposed or what ever), | |||
|
56 | // but OnStop method also locks on the same object and will handle operation in m_pending | |||
|
57 | m_pending = new ActionTask( | |||
|
58 | () => { | |||
|
59 | // only one operation is running, it's safe to assing m_pending from it | |||
|
60 | m_pending = null; | |||
|
61 | }, | |||
|
62 | ex => { | |||
|
63 | try { | |||
|
64 | OnTickError(ex); | |||
|
65 | // Analysis disable once EmptyGeneralCatchClause | |||
|
66 | } catch { | |||
|
67 | } finally { | |||
|
68 | m_pending = null; | |||
|
69 | } | |||
|
70 | // suppress error | |||
|
71 | }, | |||
|
72 | ex => { | |||
|
73 | try { | |||
|
74 | OnTickCancel(ex); | |||
|
75 | // Analysis disable once EmptyGeneralCatchClause | |||
|
76 | } catch { | |||
|
77 | } finally { | |||
|
78 | m_pending = null; | |||
|
79 | } | |||
|
80 | // supress cancellation | |||
|
81 | }, | |||
|
82 | false | |||
|
83 | ); | |||
|
84 | return true; | |||
|
85 | } | |||
|
86 | } | |||
|
87 | ||||
|
88 | /// <summary> | |||
|
89 | /// Awaits the tick. | |||
|
90 | /// </summary> | |||
|
91 | /// <param name="tick">Tick.</param> | |||
|
92 | /// <remarks> | |||
|
93 | /// This method is called only after StartTick method and m_pending will hold the promise which should be fulfilled. | |||
|
94 | /// </remarks> | |||
|
95 | void AwaitTick(IPromise tick) { | |||
|
96 | if (tick == null) { | |||
|
97 | m_pending.Resolve(); | |||
|
98 | } else { | |||
|
99 | tick.On( | |||
|
100 | m_pending.Resolve, | |||
|
101 | m_pending.Reject, | |||
|
102 | m_pending.CancelOperation | |||
|
103 | ); | |||
|
104 | } | |||
|
105 | } | |||
|
106 | ||||
|
107 | /// <summary> | |||
|
108 | /// Handles the tick error. | |||
|
109 | /// </summary> | |||
|
110 | /// <remarks> | |||
|
111 | /// This method is called only after StartTick method and m_pending will hold the promise which should be fulfilled. | |||
|
112 | /// </remarks> | |||
|
113 | void HandleTickError(Exception error) { | |||
|
114 | m_pending.Reject(error); | |||
|
115 | } | |||
|
116 | ||||
|
117 | protected virtual void OnTickError(Exception error) { | |||
|
118 | } | |||
|
119 | ||||
|
120 | protected virtual void OnTickCancel(Exception error) { | |||
|
121 | } | |||
|
122 | ||||
|
123 | /// <summary> | |||
|
124 | /// Invoked when the timer ticks, use this method to implement your logic | |||
|
125 | /// </summary> | |||
|
126 | protected virtual IPromise OnTick(ICancellationToken cancellationToken) { | |||
|
127 | return Promise.SUCCESS; | |||
|
128 | } | |||
|
129 | ||||
|
130 | protected override IPromise OnStop() { | |||
|
131 | m_timer.Change(-1, -1); | |||
|
132 | ||||
|
133 | // the component is in the stopping state | |||
|
134 | lock (m_lock) { | |||
|
135 | // after this lock no more pending operations could be created | |||
|
136 | var pending = m_pending; | |||
|
137 | // m_pending could be fulfilled and set to null already | |||
|
138 | if (pending != null) { | |||
|
139 | pending.Cancel(); | |||
|
140 | return pending.Then(base.OnStop); | |||
|
141 | } | |||
|
142 | } | |||
|
143 | ||||
|
144 | return base.OnStop(); | |||
|
145 | } | |||
|
146 | ||||
|
147 | protected override void Dispose(bool disposing, Exception lastError) { | |||
|
148 | if (disposing) | |||
|
149 | Safe.Dispose(m_timer); | |||
|
150 | ||||
|
151 | base.Dispose(disposing, lastError); | |||
|
152 | } | |||
|
153 | } | |||
|
154 | } | |||
|
155 |
@@ -0,0 +1,100 | |||||
|
1 | using System; | |||
|
2 | using System.Reflection; | |||
|
3 | ||||
|
4 | namespace Implab { | |||
|
5 | public class FailedPromise : IPromise { | |||
|
6 | readonly Exception m_error; | |||
|
7 | public FailedPromise(Exception error) { | |||
|
8 | Safe.ArgumentNotNull(error, "error"); | |||
|
9 | m_error = error; | |||
|
10 | } | |||
|
11 | ||||
|
12 | #region IPromise implementation | |||
|
13 | ||||
|
14 | public IPromise On(Action success, Action<Exception> error, Action<Exception> cancel) { | |||
|
15 | if (error != null) { | |||
|
16 | try { | |||
|
17 | error(m_error); | |||
|
18 | // Analysis disable once EmptyGeneralCatchClause | |||
|
19 | } catch { | |||
|
20 | } | |||
|
21 | } | |||
|
22 | return this; | |||
|
23 | } | |||
|
24 | ||||
|
25 | public IPromise On(Action success, Action<Exception> error) { | |||
|
26 | if (error != null) { | |||
|
27 | try { | |||
|
28 | error(m_error); | |||
|
29 | // Analysis disable once EmptyGeneralCatchClause | |||
|
30 | } catch { | |||
|
31 | } | |||
|
32 | } | |||
|
33 | return this; | |||
|
34 | } | |||
|
35 | ||||
|
36 | public IPromise On(Action success) { | |||
|
37 | return this; | |||
|
38 | } | |||
|
39 | ||||
|
40 | public IPromise On(Action handler, PromiseEventType events) { | |||
|
41 | if ((events & PromiseEventType.Error) != 0) { | |||
|
42 | try { | |||
|
43 | handler(); | |||
|
44 | // Analysis disable once EmptyGeneralCatchClause | |||
|
45 | } catch { | |||
|
46 | } | |||
|
47 | } | |||
|
48 | return this; | |||
|
49 | } | |||
|
50 | ||||
|
51 | public IPromise<T> Cast<T>() { | |||
|
52 | return (IPromise<T>)this; | |||
|
53 | } | |||
|
54 | ||||
|
55 | public void Join() { | |||
|
56 | throw new TargetInvocationException(Error); | |||
|
57 | } | |||
|
58 | ||||
|
59 | public void Join(int timeout) { | |||
|
60 | throw new TargetInvocationException(Error); | |||
|
61 | } | |||
|
62 | ||||
|
63 | public virtual Type PromiseType { | |||
|
64 | get { | |||
|
65 | return typeof(void); | |||
|
66 | } | |||
|
67 | } | |||
|
68 | ||||
|
69 | public bool IsResolved { | |||
|
70 | get { | |||
|
71 | return true; | |||
|
72 | } | |||
|
73 | } | |||
|
74 | ||||
|
75 | public bool IsCancelled { | |||
|
76 | get { | |||
|
77 | return false; | |||
|
78 | } | |||
|
79 | } | |||
|
80 | ||||
|
81 | public Exception Error { | |||
|
82 | get { | |||
|
83 | return m_error; | |||
|
84 | } | |||
|
85 | } | |||
|
86 | ||||
|
87 | #endregion | |||
|
88 | ||||
|
89 | #region ICancellable implementation | |||
|
90 | ||||
|
91 | public void Cancel() { | |||
|
92 | } | |||
|
93 | ||||
|
94 | public void Cancel(Exception reason) { | |||
|
95 | } | |||
|
96 | ||||
|
97 | #endregion | |||
|
98 | } | |||
|
99 | } | |||
|
100 |
@@ -0,0 +1,65 | |||||
|
1 | using System; | |||
|
2 | using System.Reflection; | |||
|
3 | ||||
|
4 | namespace Implab { | |||
|
5 | public class FailedPromise<T> : FailedPromise, IPromise<T> { | |||
|
6 | public FailedPromise(Exception error) : base(error) { | |||
|
7 | } | |||
|
8 | ||||
|
9 | public IPromise<T> On(Action<T> success, Action<Exception> error, Action<Exception> cancel) { | |||
|
10 | if (error != null) { | |||
|
11 | try { | |||
|
12 | error(Error); | |||
|
13 | // Analysis disable once EmptyGeneralCatchClause | |||
|
14 | } catch { | |||
|
15 | } | |||
|
16 | } | |||
|
17 | return this; | |||
|
18 | } | |||
|
19 | ||||
|
20 | public IPromise<T> On(Action<T> success, Action<Exception> error) { | |||
|
21 | if (error != null) { | |||
|
22 | try { | |||
|
23 | error(Error); | |||
|
24 | // Analysis disable once EmptyGeneralCatchClause | |||
|
25 | } catch { | |||
|
26 | } | |||
|
27 | } | |||
|
28 | return this; | |||
|
29 | } | |||
|
30 | ||||
|
31 | public IPromise<T> On(Action<T> success) { | |||
|
32 | return this; | |||
|
33 | } | |||
|
34 | ||||
|
35 | T IPromise<T>.Join() { | |||
|
36 | throw new TargetInvocationException(Error); | |||
|
37 | } | |||
|
38 | ||||
|
39 | T IPromise<T>.Join(int timeout) { | |||
|
40 | throw new TargetInvocationException(Error); | |||
|
41 | } | |||
|
42 | ||||
|
43 | ||||
|
44 | IPromise<T> IPromise<T>.On(Action success, Action<Exception> error, Action<Exception> cancel) { | |||
|
45 | On(success, error, cancel); | |||
|
46 | return this; | |||
|
47 | } | |||
|
48 | ||||
|
49 | IPromise<T> IPromise<T>.On(Action success, Action<Exception> error) { | |||
|
50 | On(success, error); | |||
|
51 | return this; | |||
|
52 | } | |||
|
53 | ||||
|
54 | IPromise<T> IPromise<T>.On(Action success) { | |||
|
55 | On(success); | |||
|
56 | return this; | |||
|
57 | } | |||
|
58 | ||||
|
59 | IPromise<T> IPromise<T>.On(Action handler, PromiseEventType events) { | |||
|
60 | On(handler, events); | |||
|
61 | return this; | |||
|
62 | } | |||
|
63 | } | |||
|
64 | } | |||
|
65 |
@@ -1,69 +1,75 | |||||
1 | <?xml version="1.0" encoding="utf-8"?> |
|
1 | <?xml version="1.0" encoding="utf-8"?> | |
2 | <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> |
|
2 | <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> | |
3 | <PropertyGroup> |
|
3 | <PropertyGroup> | |
4 | <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> |
|
4 | <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> | |
5 | <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> |
|
5 | <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> | |
6 | <ProductVersion>8.0.30703</ProductVersion> |
|
6 | <ProductVersion>8.0.30703</ProductVersion> | |
7 | <SchemaVersion>2.0</SchemaVersion> |
|
7 | <SchemaVersion>2.0</SchemaVersion> | |
8 | <ProjectGuid>{2BD05F84-E067-4B87-9477-FDC2676A21C6}</ProjectGuid> |
|
8 | <ProjectGuid>{2BD05F84-E067-4B87-9477-FDC2676A21C6}</ProjectGuid> | |
9 | <OutputType>Library</OutputType> |
|
9 | <OutputType>Library</OutputType> | |
10 | <RootNamespace>Implab.Test</RootNamespace> |
|
10 | <RootNamespace>Implab.Test</RootNamespace> | |
11 | <AssemblyName>Implab.Test</AssemblyName> |
|
11 | <AssemblyName>Implab.Test</AssemblyName> | |
12 | <TargetFrameworkVersion>v4.5</TargetFrameworkVersion> |
|
12 | <TargetFrameworkVersion>v4.5</TargetFrameworkVersion> | |
13 | <ReleaseVersion>0.2</ReleaseVersion> |
|
13 | <ReleaseVersion>0.2</ReleaseVersion> | |
14 | </PropertyGroup> |
|
14 | </PropertyGroup> | |
15 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' "> |
|
15 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' "> | |
16 | <DebugSymbols>true</DebugSymbols> |
|
16 | <DebugSymbols>true</DebugSymbols> | |
17 | <DebugType>full</DebugType> |
|
17 | <DebugType>full</DebugType> | |
18 | <Optimize>false</Optimize> |
|
18 | <Optimize>false</Optimize> | |
19 | <OutputPath>bin\Debug</OutputPath> |
|
19 | <OutputPath>bin\Debug</OutputPath> | |
20 | <DefineConstants>DEBUG;MONO</DefineConstants> |
|
20 | <DefineConstants>DEBUG;MONO</DefineConstants> | |
21 | <ErrorReport>prompt</ErrorReport> |
|
21 | <ErrorReport>prompt</ErrorReport> | |
22 | <WarningLevel>4</WarningLevel> |
|
22 | <WarningLevel>4</WarningLevel> | |
23 | <ConsolePause>false</ConsolePause> |
|
23 | <ConsolePause>false</ConsolePause> | |
24 | </PropertyGroup> |
|
24 | </PropertyGroup> | |
25 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' "> |
|
25 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' "> | |
26 | <Optimize>true</Optimize> |
|
26 | <Optimize>true</Optimize> | |
27 | <OutputPath>bin\Release</OutputPath> |
|
27 | <OutputPath>bin\Release</OutputPath> | |
28 | <ErrorReport>prompt</ErrorReport> |
|
28 | <ErrorReport>prompt</ErrorReport> | |
29 | <WarningLevel>4</WarningLevel> |
|
29 | <WarningLevel>4</WarningLevel> | |
30 | <ConsolePause>false</ConsolePause> |
|
30 | <ConsolePause>false</ConsolePause> | |
31 | <DefineConstants>MONO</DefineConstants> |
|
31 | <DefineConstants>MONO</DefineConstants> | |
32 | </PropertyGroup> |
|
32 | </PropertyGroup> | |
33 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug 4.5|AnyCPU' "> |
|
33 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug 4.5|AnyCPU' "> | |
34 | <DebugSymbols>true</DebugSymbols> |
|
34 | <DebugSymbols>true</DebugSymbols> | |
35 | <DebugType>full</DebugType> |
|
35 | <DebugType>full</DebugType> | |
36 | <Optimize>false</Optimize> |
|
36 | <Optimize>false</Optimize> | |
37 | <OutputPath>bin\Debug</OutputPath> |
|
37 | <OutputPath>bin\Debug</OutputPath> | |
38 | <DefineConstants>DEBUG;TRACE;NET_4_5;MONO</DefineConstants> |
|
38 | <DefineConstants>DEBUG;TRACE;NET_4_5;MONO</DefineConstants> | |
39 | <ErrorReport>prompt</ErrorReport> |
|
39 | <ErrorReport>prompt</ErrorReport> | |
40 | <WarningLevel>4</WarningLevel> |
|
40 | <WarningLevel>4</WarningLevel> | |
41 | <ConsolePause>false</ConsolePause> |
|
41 | <ConsolePause>false</ConsolePause> | |
42 | </PropertyGroup> |
|
42 | </PropertyGroup> | |
43 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release 4.5|AnyCPU' "> |
|
43 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release 4.5|AnyCPU' "> | |
44 | <Optimize>true</Optimize> |
|
44 | <Optimize>true</Optimize> | |
45 | <OutputPath>bin\Release</OutputPath> |
|
45 | <OutputPath>bin\Release</OutputPath> | |
46 | <DefineConstants>NET_4_5;MONO</DefineConstants> |
|
46 | <DefineConstants>NET_4_5;MONO</DefineConstants> | |
47 | <ErrorReport>prompt</ErrorReport> |
|
47 | <ErrorReport>prompt</ErrorReport> | |
48 | <WarningLevel>4</WarningLevel> |
|
48 | <WarningLevel>4</WarningLevel> | |
49 | <ConsolePause>false</ConsolePause> |
|
49 | <ConsolePause>false</ConsolePause> | |
50 | </PropertyGroup> |
|
50 | </PropertyGroup> | |
51 | <ItemGroup> |
|
51 | <ItemGroup> | |
52 | <Reference Include="System" /> |
|
52 | <Reference Include="System" /> | |
53 | <Reference Include="nunit.framework" /> |
|
53 | <Reference Include="nunit.framework" /> | |
54 | </ItemGroup> |
|
54 | </ItemGroup> | |
55 | <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" /> |
|
55 | <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" /> | |
56 | <ItemGroup> |
|
56 | <ItemGroup> | |
57 | <Compile Include="AsyncTests.cs" /> |
|
57 | <Compile Include="AsyncTests.cs" /> | |
58 | <Compile Include="PromiseHelper.cs" /> |
|
58 | <Compile Include="PromiseHelper.cs" /> | |
59 | <Compile Include="Properties\AssemblyInfo.cs" /> |
|
59 | <Compile Include="Properties\AssemblyInfo.cs" /> | |
60 | <Compile Include="CancelationTests.cs" /> |
|
60 | <Compile Include="CancelationTests.cs" /> | |
61 | <Compile Include="RunnableComponentTests.cs" /> |
|
61 | <Compile Include="RunnableComponentTests.cs" /> | |
|
62 | <Compile Include="PollingComponentTests.cs" /> | |||
|
63 | <Compile Include="Mock\MockRunnableComponent.cs" /> | |||
|
64 | <Compile Include="Mock\MockPollingComponent.cs" /> | |||
62 | </ItemGroup> |
|
65 | </ItemGroup> | |
63 | <ItemGroup> |
|
66 | <ItemGroup> | |
64 | <ProjectReference Include="..\Implab\Implab.csproj"> |
|
67 | <ProjectReference Include="..\Implab\Implab.csproj"> | |
65 | <Project>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</Project> |
|
68 | <Project>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</Project> | |
66 | <Name>Implab</Name> |
|
69 | <Name>Implab</Name> | |
67 | </ProjectReference> |
|
70 | </ProjectReference> | |
68 | </ItemGroup> |
|
71 | </ItemGroup> | |
|
72 | <ItemGroup> | |||
|
73 | <Folder Include="Mock\" /> | |||
|
74 | </ItemGroup> | |||
69 | </Project> No newline at end of file |
|
75 | </Project> |
@@ -1,14 +1,22 | |||||
1 | using Implab.Parallels; |
|
1 | using Implab.Parallels; | |
2 | using System.Threading; |
|
2 | using System.Threading; | |
3 |
|
3 | |||
4 | namespace Implab.Test { |
|
4 | namespace Implab.Test { | |
5 | static class PromiseHelper { |
|
5 | static class PromiseHelper { | |
6 | public static IPromise<T> Sleep<T>(int timeout, T retVal) { |
|
6 | public static IPromise<T> Sleep<T>(int timeout, T retVal) { | |
7 | return AsyncPool.Invoke((ct) => { |
|
7 | return AsyncPool.Invoke((ct) => { | |
8 | ct.CancellationRequested(ct.CancelOperation); |
|
8 | ct.CancellationRequested(ct.CancelOperation); | |
9 | Thread.Sleep(timeout); |
|
9 | Thread.Sleep(timeout); | |
10 | return retVal; |
|
10 | return retVal; | |
11 | }); |
|
11 | }); | |
12 | } |
|
12 | } | |
|
13 | ||||
|
14 | public static IPromise Sleep(int timeout) { | |||
|
15 | return AsyncPool.Invoke((ct) => { | |||
|
16 | ct.CancellationRequested(ct.CancelOperation); | |||
|
17 | Thread.Sleep(timeout); | |||
|
18 | return 0; | |||
|
19 | }); | |||
|
20 | } | |||
13 | } |
|
21 | } | |
14 | } |
|
22 | } |
@@ -1,195 +1,165 | |||||
1 | using System; |
|
1 | using System; | |
2 | using System.Reflection; |
|
2 | using System.Reflection; | |
3 | using System.Threading; |
|
3 | using System.Threading; | |
4 | using Implab.Parallels; |
|
4 | using Implab.Parallels; | |
5 | using Implab.Components; |
|
5 | using Implab.Components; | |
|
6 | using Implab.Test.Mock; | |||
6 |
|
7 | |||
7 | #if MONO |
|
8 | #if MONO | |
8 |
|
9 | |||
9 | using NUnit.Framework; |
|
10 | using NUnit.Framework; | |
10 | using TestClassAttribute = NUnit.Framework.TestFixtureAttribute; |
|
11 | using TestClassAttribute = NUnit.Framework.TestFixtureAttribute; | |
11 | using TestMethodAttribute = NUnit.Framework.TestAttribute; |
|
12 | using TestMethodAttribute = NUnit.Framework.TestAttribute; | |
12 | using AssertFailedException = NUnit.Framework.AssertionException; |
|
13 | using AssertFailedException = NUnit.Framework.AssertionException; | |
13 | #else |
|
14 | #else | |
14 |
|
15 | |||
15 | using Microsoft.VisualStudio.TestTools.UnitTesting; |
|
16 | using Microsoft.VisualStudio.TestTools.UnitTesting; | |
16 |
|
17 | |||
17 | #endif |
|
18 | #endif | |
18 |
|
19 | |||
19 | namespace Implab.Test { |
|
20 | namespace Implab.Test { | |
20 | [TestClass] |
|
21 | [TestClass] | |
21 | public class RunnableComponentTests { |
|
22 | public class RunnableComponentTests { | |
22 |
|
23 | |||
23 | static void ShouldThrow(Action action) { |
|
24 | static void ShouldThrow(Action action) { | |
24 | try { |
|
25 | try { | |
25 | action(); |
|
26 | action(); | |
26 | Assert.Fail(); |
|
27 | Assert.Fail(); | |
27 | } catch (AssertFailedException) { |
|
28 | } catch (AssertFailedException) { | |
28 | throw; |
|
29 | throw; | |
29 | } catch { |
|
30 | } catch { | |
30 | } |
|
31 | } | |
31 | } |
|
32 | } | |
32 |
|
33 | |||
33 | class Runnable : RunnableComponent { |
|
|||
34 | public Runnable(bool initialized) : base(initialized) { |
|
|||
35 | } |
|
|||
36 |
|
||||
37 | public Action MockInit { |
|
|||
38 | get; |
|
|||
39 | set; |
|
|||
40 | } |
|
|||
41 |
|
|
34 | ||
42 | public Func<IPromise> MockStart { |
|
|||
43 | get; |
|
|||
44 | set; |
|
|||
45 | } |
|
|||
46 |
|
||||
47 | public Func<IPromise> MockStop { |
|
|||
48 | get; |
|
|||
49 | set; |
|
|||
50 | } |
|
|||
51 |
|
||||
52 | protected override IPromise OnStart() { |
|
|||
53 | return MockStart != null ? MockStart() : base.OnStart(); |
|
|||
54 | } |
|
|||
55 |
|
||||
56 | protected override IPromise OnStop() { |
|
|||
57 | return MockStop != null ? MockStop() : base.OnStart(); |
|
|||
58 | } |
|
|||
59 |
|
||||
60 | protected override void OnInitialize() { |
|
|||
61 | if (MockInit != null) |
|
|||
62 | MockInit(); |
|
|||
63 | } |
|
|||
64 | } |
|
|||
65 |
|
|
35 | ||
66 | [TestMethod] |
|
36 | [TestMethod] | |
67 | public void NormalFlowTest() { |
|
37 | public void NormalFlowTest() { | |
68 | var comp = new Runnable(false); |
|
38 | var comp = new MockRunnableComponent(false); | |
69 |
|
39 | |||
70 | Assert.AreEqual(ExecutionState.Created, comp.State); |
|
40 | Assert.AreEqual(ExecutionState.Created, comp.State); | |
71 |
|
41 | |||
72 | comp.Init(); |
|
42 | comp.Init(); | |
73 |
|
43 | |||
74 | Assert.AreEqual(ExecutionState.Ready, comp.State); |
|
44 | Assert.AreEqual(ExecutionState.Ready, comp.State); | |
75 |
|
45 | |||
76 | comp.Start().Join(1000); |
|
46 | comp.Start().Join(1000); | |
77 |
|
47 | |||
78 | Assert.AreEqual(ExecutionState.Running, comp.State); |
|
48 | Assert.AreEqual(ExecutionState.Running, comp.State); | |
79 |
|
49 | |||
80 | comp.Stop().Join(1000); |
|
50 | comp.Stop().Join(1000); | |
81 |
|
51 | |||
82 | Assert.AreEqual(ExecutionState.Disposed, comp.State); |
|
52 | Assert.AreEqual(ExecutionState.Disposed, comp.State); | |
83 |
|
53 | |||
84 | } |
|
54 | } | |
85 |
|
55 | |||
86 | [TestMethod] |
|
56 | [TestMethod] | |
87 | public void InitFailTest() { |
|
57 | public void InitFailTest() { | |
88 | var comp = new Runnable(false) { |
|
58 | var comp = new MockRunnableComponent(false) { | |
89 | MockInit = () => { |
|
59 | MockInit = () => { | |
90 | throw new Exception("BAD"); |
|
60 | throw new Exception("BAD"); | |
91 | } |
|
61 | } | |
92 | }; |
|
62 | }; | |
93 |
|
63 | |||
94 | ShouldThrow(() => comp.Start()); |
|
64 | ShouldThrow(() => comp.Start()); | |
95 | ShouldThrow(() => comp.Stop()); |
|
65 | ShouldThrow(() => comp.Stop()); | |
96 | Assert.AreEqual(ExecutionState.Created, comp.State); |
|
66 | Assert.AreEqual(ExecutionState.Created, comp.State); | |
97 |
|
67 | |||
98 | ShouldThrow(comp.Init); |
|
68 | ShouldThrow(comp.Init); | |
99 |
|
69 | |||
100 | Assert.AreEqual(ExecutionState.Failed, comp.State); |
|
70 | Assert.AreEqual(ExecutionState.Failed, comp.State); | |
101 |
|
71 | |||
102 | ShouldThrow(() => comp.Start()); |
|
72 | ShouldThrow(() => comp.Start()); | |
103 | ShouldThrow(() => comp.Stop()); |
|
73 | ShouldThrow(() => comp.Stop()); | |
104 | Assert.AreEqual(ExecutionState.Failed, comp.State); |
|
74 | Assert.AreEqual(ExecutionState.Failed, comp.State); | |
105 |
|
75 | |||
106 | comp.Dispose(); |
|
76 | comp.Dispose(); | |
107 | Assert.AreEqual(ExecutionState.Disposed, comp.State); |
|
77 | Assert.AreEqual(ExecutionState.Disposed, comp.State); | |
108 | } |
|
78 | } | |
109 |
|
79 | |||
110 | [TestMethod] |
|
80 | [TestMethod] | |
111 | public void DisposedTest() { |
|
81 | public void DisposedTest() { | |
112 |
|
82 | |||
113 | var comp = new Runnable(false); |
|
83 | var comp = new MockRunnableComponent(false); | |
114 | comp.Dispose(); |
|
84 | comp.Dispose(); | |
115 |
|
85 | |||
116 | ShouldThrow(() => comp.Start()); |
|
86 | ShouldThrow(() => comp.Start()); | |
117 | ShouldThrow(() => comp.Stop()); |
|
87 | ShouldThrow(() => comp.Stop()); | |
118 | ShouldThrow(comp.Init); |
|
88 | ShouldThrow(comp.Init); | |
119 |
|
89 | |||
120 | Assert.AreEqual(ExecutionState.Disposed, comp.State); |
|
90 | Assert.AreEqual(ExecutionState.Disposed, comp.State); | |
121 | } |
|
91 | } | |
122 |
|
92 | |||
123 | [TestMethod] |
|
93 | [TestMethod] | |
124 | public void StartCancelTest() { |
|
94 | public void StartCancelTest() { | |
125 | var comp = new Runnable(true) { |
|
95 | var comp = new MockRunnableComponent(true) { | |
126 | MockStart = () => PromiseHelper.Sleep(100000, 0) |
|
96 | MockStart = () => PromiseHelper.Sleep(100000, 0) | |
127 | }; |
|
97 | }; | |
128 |
|
98 | |||
129 | var p = comp.Start(); |
|
99 | var p = comp.Start(); | |
130 | Assert.AreEqual(ExecutionState.Starting, comp.State); |
|
100 | Assert.AreEqual(ExecutionState.Starting, comp.State); | |
131 | p.Cancel(); |
|
101 | p.Cancel(); | |
132 | ShouldThrow(() => p.Join(1000)); |
|
102 | ShouldThrow(() => p.Join(1000)); | |
133 | Assert.AreEqual(ExecutionState.Failed, comp.State); |
|
103 | Assert.AreEqual(ExecutionState.Failed, comp.State); | |
134 |
|
104 | |||
135 | Assert.IsTrue(comp.LastError is OperationCanceledException); |
|
105 | Assert.IsTrue(comp.LastError is OperationCanceledException); | |
136 |
|
106 | |||
137 | comp.Dispose(); |
|
107 | comp.Dispose(); | |
138 | } |
|
108 | } | |
139 |
|
109 | |||
140 | [TestMethod] |
|
110 | [TestMethod] | |
141 | public void StartStopTest() { |
|
111 | public void StartStopTest() { | |
142 | var stop = new Signal(); |
|
112 | var stop = new Signal(); | |
143 | var comp = new Runnable(true) { |
|
113 | var comp = new MockRunnableComponent(true) { | |
144 | MockStart = () => PromiseHelper.Sleep(100000, 0), |
|
114 | MockStart = () => PromiseHelper.Sleep(100000, 0), | |
145 | MockStop = () => AsyncPool.RunThread(stop.Wait) |
|
115 | MockStop = () => AsyncPool.RunThread(stop.Wait) | |
146 | }; |
|
116 | }; | |
147 |
|
117 | |||
148 | var p1 = comp.Start(); |
|
118 | var p1 = comp.Start(); | |
149 | var p2 = comp.Stop(); |
|
119 | var p2 = comp.Stop(); | |
150 | // should enter stopping state |
|
120 | // should enter stopping state | |
151 |
|
121 | |||
152 | ShouldThrow(p1.Join); |
|
122 | ShouldThrow(p1.Join); | |
153 | Assert.IsTrue(p1.IsCancelled); |
|
123 | Assert.IsTrue(p1.IsCancelled); | |
154 | Assert.AreEqual(ExecutionState.Stopping, comp.State); |
|
124 | Assert.AreEqual(ExecutionState.Stopping, comp.State); | |
155 |
|
125 | |||
156 | stop.Set(); |
|
126 | stop.Set(); | |
157 | p2.Join(1000); |
|
127 | p2.Join(1000); | |
158 | Assert.AreEqual(ExecutionState.Disposed, comp.State); |
|
128 | Assert.AreEqual(ExecutionState.Disposed, comp.State); | |
159 | } |
|
129 | } | |
160 |
|
130 | |||
161 | [TestMethod] |
|
131 | [TestMethod] | |
162 | public void StartStopFailTest() { |
|
132 | public void StartStopFailTest() { | |
163 | var comp = new Runnable(true) { |
|
133 | var comp = new MockRunnableComponent(true) { | |
164 | MockStart = () => PromiseHelper.Sleep(100000, 0).Then(null,null,x => { throw new Exception("I'm dead"); }) |
|
134 | MockStart = () => PromiseHelper.Sleep(100000, 0).Then(null,null,x => { throw new Exception("I'm dead"); }) | |
165 | }; |
|
135 | }; | |
166 |
|
136 | |||
167 | comp.Start(); |
|
137 | comp.Start(); | |
168 | var p = comp.Stop(); |
|
138 | var p = comp.Stop(); | |
169 | // if Start fails to cancel, should fail to stop |
|
139 | // if Start fails to cancel, should fail to stop | |
170 | ShouldThrow(() => p.Join(1000)); |
|
140 | ShouldThrow(() => p.Join(1000)); | |
171 | Assert.AreEqual(ExecutionState.Failed, comp.State); |
|
141 | Assert.AreEqual(ExecutionState.Failed, comp.State); | |
172 | Assert.IsNotNull(comp.LastError); |
|
142 | Assert.IsNotNull(comp.LastError); | |
173 | Assert.AreEqual("I'm dead", comp.LastError.Message); |
|
143 | Assert.AreEqual("I'm dead", comp.LastError.Message); | |
174 | } |
|
144 | } | |
175 |
|
145 | |||
176 | [TestMethod] |
|
146 | [TestMethod] | |
177 | public void StopCancelTest() { |
|
147 | public void StopCancelTest() { | |
178 | var comp = new Runnable(true) { |
|
148 | var comp = new MockRunnableComponent(true) { | |
179 | MockStop = () => PromiseHelper.Sleep(100000, 0) |
|
149 | MockStop = () => PromiseHelper.Sleep(100000, 0) | |
180 | }; |
|
150 | }; | |
181 |
|
151 | |||
182 | comp.Start(); |
|
152 | comp.Start(); | |
183 | var p = comp.Stop(); |
|
153 | var p = comp.Stop(); | |
184 | Assert.AreEqual(ExecutionState.Stopping, comp.State); |
|
154 | Assert.AreEqual(ExecutionState.Stopping, comp.State); | |
185 | p.Cancel(); |
|
155 | p.Cancel(); | |
186 | ShouldThrow(() => p.Join(1000)); |
|
156 | ShouldThrow(() => p.Join(1000)); | |
187 | Assert.AreEqual(ExecutionState.Failed, comp.State); |
|
157 | Assert.AreEqual(ExecutionState.Failed, comp.State); | |
188 | Assert.IsTrue(comp.LastError is OperationCanceledException); |
|
158 | Assert.IsTrue(comp.LastError is OperationCanceledException); | |
189 |
|
159 | |||
190 | comp.Dispose(); |
|
160 | comp.Dispose(); | |
191 | } |
|
161 | } | |
192 |
|
162 | |||
193 | } |
|
163 | } | |
194 | } |
|
164 | } | |
195 |
|
165 |
@@ -1,14 +1,20 | |||||
1 | using System; |
|
1 | using System; | |
2 |
|
2 | |||
3 | namespace Implab.Components { |
|
3 | namespace Implab.Components { | |
4 | public interface IRunnable { |
|
4 | public interface IRunnable { | |
|
5 | /// <summary> | |||
|
6 | /// Starts this instance. | |||
|
7 | /// </summary> | |||
5 | IPromise Start(); |
|
8 | IPromise Start(); | |
6 |
|
9 | |||
|
10 | /// <summary> | |||
|
11 | /// Stops this instance. After the instance is stopped it can't be started again, stopping should be treated as gracefull and async dispose. | |||
|
12 | /// </summary> | |||
7 | IPromise Stop(); |
|
13 | IPromise Stop(); | |
8 |
|
14 | |||
9 | ExecutionState State { get; } |
|
15 | ExecutionState State { get; } | |
10 |
|
16 | |||
11 | Exception LastError { get; } |
|
17 | Exception LastError { get; } | |
12 | } |
|
18 | } | |
13 | } |
|
19 | } | |
14 |
|
20 |
@@ -1,265 +1,296 | |||||
1 | using System; |
|
1 | using System; | |
2 |
|
2 | |||
3 | namespace Implab.Components { |
|
3 | namespace Implab.Components { | |
4 | public abstract class RunnableComponent : IDisposable, IRunnable, IInitializable { |
|
4 | public abstract class RunnableComponent : IDisposable, IRunnable, IInitializable { | |
5 | enum Commands { |
|
5 | enum Commands { | |
6 | Ok = 0, |
|
6 | Ok = 0, | |
7 | Fail, |
|
7 | Fail, | |
8 | Init, |
|
8 | Init, | |
9 | Start, |
|
9 | Start, | |
10 | Stop, |
|
10 | Stop, | |
11 | Dispose, |
|
11 | Dispose, | |
12 | Last = Dispose |
|
12 | Last = Dispose | |
13 | } |
|
13 | } | |
14 |
|
14 | |||
15 | class StateMachine { |
|
15 | class StateMachine { | |
16 | static readonly ExecutionState[,] _transitions; |
|
16 | static readonly ExecutionState[,] _transitions; | |
17 |
|
17 | |||
18 | static StateMachine() { |
|
18 | static StateMachine() { | |
19 | _transitions = new ExecutionState[(int)ExecutionState.Last + 1, (int)Commands.Last + 1]; |
|
19 | _transitions = new ExecutionState[(int)ExecutionState.Last + 1, (int)Commands.Last + 1]; | |
20 |
|
20 | |||
21 | Edge(ExecutionState.Created, ExecutionState.Initializing, Commands.Init); |
|
21 | Edge(ExecutionState.Created, ExecutionState.Initializing, Commands.Init); | |
22 | Edge(ExecutionState.Created, ExecutionState.Disposed, Commands.Dispose); |
|
22 | Edge(ExecutionState.Created, ExecutionState.Disposed, Commands.Dispose); | |
23 |
|
23 | |||
24 | Edge(ExecutionState.Initializing, ExecutionState.Ready, Commands.Ok); |
|
24 | Edge(ExecutionState.Initializing, ExecutionState.Ready, Commands.Ok); | |
25 | Edge(ExecutionState.Initializing, ExecutionState.Failed, Commands.Fail); |
|
25 | Edge(ExecutionState.Initializing, ExecutionState.Failed, Commands.Fail); | |
26 |
|
26 | |||
27 | Edge(ExecutionState.Ready, ExecutionState.Starting, Commands.Start); |
|
27 | Edge(ExecutionState.Ready, ExecutionState.Starting, Commands.Start); | |
28 | Edge(ExecutionState.Ready, ExecutionState.Disposed, Commands.Dispose); |
|
28 | Edge(ExecutionState.Ready, ExecutionState.Disposed, Commands.Dispose); | |
29 |
|
29 | |||
30 | Edge(ExecutionState.Starting, ExecutionState.Running, Commands.Ok); |
|
30 | Edge(ExecutionState.Starting, ExecutionState.Running, Commands.Ok); | |
31 | Edge(ExecutionState.Starting, ExecutionState.Failed, Commands.Fail); |
|
31 | Edge(ExecutionState.Starting, ExecutionState.Failed, Commands.Fail); | |
32 | Edge(ExecutionState.Starting, ExecutionState.Stopping, Commands.Stop); |
|
32 | Edge(ExecutionState.Starting, ExecutionState.Stopping, Commands.Stop); | |
33 | Edge(ExecutionState.Starting, ExecutionState.Disposed, Commands.Dispose); |
|
33 | Edge(ExecutionState.Starting, ExecutionState.Disposed, Commands.Dispose); | |
34 |
|
34 | |||
35 | Edge(ExecutionState.Running, ExecutionState.Failed, Commands.Fail); |
|
35 | Edge(ExecutionState.Running, ExecutionState.Failed, Commands.Fail); | |
36 | Edge(ExecutionState.Running, ExecutionState.Stopping, Commands.Stop); |
|
36 | Edge(ExecutionState.Running, ExecutionState.Stopping, Commands.Stop); | |
37 | Edge(ExecutionState.Running, ExecutionState.Disposed, Commands.Dispose); |
|
37 | Edge(ExecutionState.Running, ExecutionState.Disposed, Commands.Dispose); | |
38 |
|
38 | |||
39 | Edge(ExecutionState.Stopping, ExecutionState.Failed, Commands.Fail); |
|
39 | Edge(ExecutionState.Stopping, ExecutionState.Failed, Commands.Fail); | |
40 | Edge(ExecutionState.Stopping, ExecutionState.Disposed, Commands.Ok); |
|
40 | Edge(ExecutionState.Stopping, ExecutionState.Disposed, Commands.Ok); | |
41 |
|
41 | |||
42 | Edge(ExecutionState.Failed, ExecutionState.Disposed, Commands.Dispose); |
|
42 | Edge(ExecutionState.Failed, ExecutionState.Disposed, Commands.Dispose); | |
43 | } |
|
43 | } | |
44 |
|
44 | |||
45 | static void Edge(ExecutionState s1, ExecutionState s2, Commands cmd) { |
|
45 | static void Edge(ExecutionState s1, ExecutionState s2, Commands cmd) { | |
46 | _transitions[(int)s1, (int)cmd] = s2; |
|
46 | _transitions[(int)s1, (int)cmd] = s2; | |
47 | } |
|
47 | } | |
48 |
|
48 | |||
49 | public ExecutionState State { |
|
49 | public ExecutionState State { | |
50 | get; |
|
50 | get; | |
51 | private set; |
|
51 | private set; | |
52 | } |
|
52 | } | |
53 |
|
53 | |||
54 | public StateMachine(ExecutionState initial) { |
|
54 | public StateMachine(ExecutionState initial) { | |
55 | State = initial; |
|
55 | State = initial; | |
56 | } |
|
56 | } | |
57 |
|
57 | |||
58 | public bool Move(Commands cmd) { |
|
58 | public bool Move(Commands cmd) { | |
59 | var next = _transitions[(int)State, (int)cmd]; |
|
59 | var next = _transitions[(int)State, (int)cmd]; | |
60 | if (next == ExecutionState.Undefined) |
|
60 | if (next == ExecutionState.Undefined) | |
61 | return false; |
|
61 | return false; | |
62 | State = next; |
|
62 | State = next; | |
63 | return true; |
|
63 | return true; | |
64 | } |
|
64 | } | |
65 | } |
|
65 | } | |
66 |
|
66 | |||
67 | IPromise m_pending; |
|
67 | IPromise m_pending; | |
68 | Exception m_lastError; |
|
68 | Exception m_lastError; | |
69 |
|
69 | |||
70 | readonly StateMachine m_stateMachine; |
|
70 | readonly StateMachine m_stateMachine; | |
71 |
|
71 | |||
72 | protected RunnableComponent(bool initialized) { |
|
72 | protected RunnableComponent(bool initialized) { | |
73 | m_stateMachine = new StateMachine(initialized ? ExecutionState.Ready : ExecutionState.Created); |
|
73 | m_stateMachine = new StateMachine(initialized ? ExecutionState.Ready : ExecutionState.Created); | |
|
74 | DisposeTimeout = 10000; | |||
74 | } |
|
75 | } | |
75 |
|
76 | |||
76 | protected virtual int DisposeTimeout { |
|
77 | /// <summary> | |
77 | get { |
|
78 | /// Gets or sets the timeout to wait for the pending operation to complete. If the pending operation doesn't finish than the component will be disposed anyway. | |
78 | return 10000; |
|
79 | /// </summary> | |
79 | } |
|
80 | protected int DisposeTimeout { | |
|
81 | get; | |||
|
82 | set; | |||
80 | } |
|
83 | } | |
81 |
|
84 | |||
82 | void ThrowInvalidCommand(Commands cmd) { |
|
85 | void ThrowInvalidCommand(Commands cmd) { | |
83 | if (m_stateMachine.State == ExecutionState.Disposed) |
|
86 | if (m_stateMachine.State == ExecutionState.Disposed) | |
84 | throw new ObjectDisposedException(ToString()); |
|
87 | throw new ObjectDisposedException(ToString()); | |
85 |
|
88 | |||
86 | throw new InvalidOperationException(String.Format("Commnd {0} is not allowed in the state {1}", cmd, m_stateMachine.State)); |
|
89 | throw new InvalidOperationException(String.Format("Commnd {0} is not allowed in the state {1}", cmd, m_stateMachine.State)); | |
87 | } |
|
90 | } | |
88 |
|
91 | |||
89 | void Move(Commands cmd) { |
|
92 | void Move(Commands cmd) { | |
90 | if (!m_stateMachine.Move(cmd)) |
|
93 | if (!m_stateMachine.Move(cmd)) | |
91 | ThrowInvalidCommand(cmd); |
|
94 | ThrowInvalidCommand(cmd); | |
92 | } |
|
95 | } | |
93 |
|
96 | |||
|
97 | /// <summary> | |||
|
98 | /// Moves the component from running to failed state. | |||
|
99 | /// </summary> | |||
|
100 | /// <param name="error">The exception which is describing the error.</param> | |||
|
101 | /// <returns>Returns true if the component is set to the failed state, false - otherwise. | |||
|
102 | /// This method works only for the running state, in any other state it will return false.</returns> | |||
|
103 | protected bool Fail(Exception error) { | |||
|
104 | lock (m_stateMachine) { | |||
|
105 | if(m_stateMachine.State == ExecutionState.Running) { | |||
|
106 | m_stateMachine.Move(Commands.Fail); | |||
|
107 | m_lastError = error; | |||
|
108 | return true; | |||
|
109 | } | |||
|
110 | } | |||
|
111 | return false; | |||
|
112 | } | |||
|
113 | ||||
94 | void Invoke(Commands cmd, Action action) { |
|
114 | void Invoke(Commands cmd, Action action) { | |
95 | lock (m_stateMachine) |
|
115 | lock (m_stateMachine) | |
96 | Move(cmd); |
|
116 | Move(cmd); | |
97 |
|
117 | |||
98 | try { |
|
118 | try { | |
99 | action(); |
|
119 | action(); | |
100 | lock(m_stateMachine) |
|
120 | lock(m_stateMachine) | |
101 | Move(Commands.Ok); |
|
121 | Move(Commands.Ok); | |
102 |
|
122 | |||
103 | } catch (Exception err) { |
|
123 | } catch (Exception err) { | |
104 | lock (m_stateMachine) { |
|
124 | lock (m_stateMachine) { | |
105 | Move(Commands.Fail); |
|
125 | Move(Commands.Fail); | |
106 | m_lastError = err; |
|
126 | m_lastError = err; | |
107 | } |
|
127 | } | |
108 | throw; |
|
128 | throw; | |
109 | } |
|
129 | } | |
110 | } |
|
130 | } | |
111 |
|
131 | |||
112 | IPromise InvokeAsync(Commands cmd, Func<IPromise> action, Action<IPromise, IDeferred> chain) { |
|
132 | IPromise InvokeAsync(Commands cmd, Func<IPromise> action, Action<IPromise, IDeferred> chain) { | |
113 | IPromise promise = null; |
|
133 | IPromise promise = null; | |
114 | IPromise prev; |
|
134 | IPromise prev; | |
115 |
|
135 | |||
116 | var task = new ActionChainTask(action, null, null, true); |
|
136 | var task = new ActionChainTask(action, null, null, true); | |
117 |
|
137 | |||
118 | lock (m_stateMachine) { |
|
138 | lock (m_stateMachine) { | |
119 | Move(cmd); |
|
139 | Move(cmd); | |
120 |
|
140 | |||
121 | prev = m_pending; |
|
141 | prev = m_pending; | |
122 |
|
142 | |||
123 | Action<Exception> errorOrCancel = e => { |
|
143 | Action<Exception> errorOrCancel = e => { | |
124 | if (e == null) |
|
144 | if (e == null) | |
125 | e = new OperationCanceledException(); |
|
145 | e = new OperationCanceledException(); | |
126 |
|
146 | |||
127 | lock (m_stateMachine) { |
|
147 | lock (m_stateMachine) { | |
128 | if (m_pending == promise) { |
|
148 | if (m_pending == promise) { | |
129 | Move(Commands.Fail); |
|
149 | Move(Commands.Fail); | |
130 | m_pending = null; |
|
150 | m_pending = null; | |
131 | m_lastError = e; |
|
151 | m_lastError = e; | |
132 | } |
|
152 | } | |
133 | } |
|
153 | } | |
134 | throw new PromiseTransientException(e); |
|
154 | throw new PromiseTransientException(e); | |
135 | }; |
|
155 | }; | |
136 |
|
156 | |||
137 | promise = task.Then( |
|
157 | promise = task.Then( | |
138 | () => { |
|
158 | () => { | |
139 | lock(m_stateMachine) { |
|
159 | lock(m_stateMachine) { | |
140 | if (m_pending == promise) { |
|
160 | if (m_pending == promise) { | |
141 | Move(Commands.Ok); |
|
161 | Move(Commands.Ok); | |
142 | m_pending = null; |
|
162 | m_pending = null; | |
143 | } |
|
163 | } | |
144 | } |
|
164 | } | |
145 | }, |
|
165 | }, | |
146 | errorOrCancel, |
|
166 | errorOrCancel, | |
147 | errorOrCancel |
|
167 | errorOrCancel | |
148 | ); |
|
168 | ); | |
149 |
|
169 | |||
150 | m_pending = promise; |
|
170 | m_pending = promise; | |
151 | } |
|
171 | } | |
152 |
|
172 | |||
153 | if (prev == null) |
|
173 | if (prev == null) | |
154 | task.Resolve(); |
|
174 | task.Resolve(); | |
155 | else |
|
175 | else | |
156 | chain(prev, task); |
|
176 | chain(prev, task); | |
157 |
|
177 | |||
158 | return promise; |
|
178 | return promise; | |
159 | } |
|
179 | } | |
160 |
|
180 | |||
161 |
|
181 | |||
162 | #region IInitializable implementation |
|
182 | #region IInitializable implementation | |
163 |
|
183 | |||
164 | public void Init() { |
|
184 | public void Init() { | |
165 | Invoke(Commands.Init, OnInitialize); |
|
185 | Invoke(Commands.Init, OnInitialize); | |
166 | } |
|
186 | } | |
167 |
|
187 | |||
168 | protected virtual void OnInitialize() { |
|
188 | protected virtual void OnInitialize() { | |
169 | } |
|
189 | } | |
170 |
|
190 | |||
171 | #endregion |
|
191 | #endregion | |
172 |
|
192 | |||
173 | #region IRunnable implementation |
|
193 | #region IRunnable implementation | |
174 |
|
194 | |||
175 | public IPromise Start() { |
|
195 | public IPromise Start() { | |
176 | return InvokeAsync(Commands.Start, OnStart, null); |
|
196 | return InvokeAsync(Commands.Start, OnStart, null); | |
177 | } |
|
197 | } | |
178 |
|
198 | |||
179 | protected virtual IPromise OnStart() { |
|
199 | protected virtual IPromise OnStart() { | |
180 | return Promise.SUCCESS; |
|
200 | return Promise.SUCCESS; | |
181 | } |
|
201 | } | |
182 |
|
202 | |||
183 | public IPromise Stop() { |
|
203 | public IPromise Stop() { | |
184 | return InvokeAsync(Commands.Stop, OnStop, StopPending).Then(Dispose); |
|
204 | return InvokeAsync(Commands.Stop, OnStop, StopPending).Then(Dispose); | |
185 | } |
|
205 | } | |
186 |
|
206 | |||
187 | protected virtual IPromise OnStop() { |
|
207 | protected virtual IPromise OnStop() { | |
188 | return Promise.SUCCESS; |
|
208 | return Promise.SUCCESS; | |
189 | } |
|
209 | } | |
190 |
|
210 | |||
191 | /// <summary> |
|
211 | /// <summary> | |
192 | /// Stops the current operation if one exists. |
|
212 | /// Stops the current operation if one exists. | |
193 | /// </summary> |
|
213 | /// </summary> | |
194 | /// <param name="current">Current.</param> |
|
214 | /// <param name="current">Current.</param> | |
195 | /// <param name="stop">Stop.</param> |
|
215 | /// <param name="stop">Stop.</param> | |
196 | protected virtual void StopPending(IPromise current, IDeferred stop) { |
|
216 | protected virtual void StopPending(IPromise current, IDeferred stop) { | |
197 | if (current == null) { |
|
217 | if (current == null) { | |
198 | stop.Resolve(); |
|
218 | stop.Resolve(); | |
199 | } else { |
|
219 | } else { | |
200 | // связваем текущую операцию с операцией остановки |
|
220 | // связваем текущую операцию с операцией остановки | |
201 | current.On( |
|
221 | current.On( | |
202 | stop.Resolve, // если текущая операция заверщилась, то можно начинать остановку |
|
222 | stop.Resolve, // если текущая операция заверщилась, то можно начинать остановку | |
203 | stop.Reject, // если текущая операция дала ошибку - то все плохо, нельзя продолжать |
|
223 | stop.Reject, // если текущая операция дала ошибку - то все плохо, нельзя продолжать | |
204 | e => stop.Resolve() // если текущая отменилась, то можно начинать остановку |
|
224 | e => stop.Resolve() // если текущая отменилась, то можно начинать остановку | |
205 | ); |
|
225 | ); | |
206 | // посылаем текущей операции сигнал остановки |
|
226 | // посылаем текущей операции сигнал остановки | |
207 | current.Cancel(); |
|
227 | current.Cancel(); | |
208 | } |
|
228 | } | |
209 | } |
|
229 | } | |
210 |
|
230 | |||
211 | public ExecutionState State { |
|
231 | public ExecutionState State { | |
212 | get { |
|
232 | get { | |
213 |
|
|
233 | return m_stateMachine.State; | |
214 | return m_stateMachine.State; |
|
|||
215 | } |
|
234 | } | |
216 | } |
|
235 | } | |
217 |
|
236 | |||
218 | public Exception LastError { |
|
237 | public Exception LastError { | |
219 | get { |
|
238 | get { | |
220 | return m_lastError; |
|
239 | return m_lastError; | |
221 | } |
|
240 | } | |
222 | } |
|
241 | } | |
223 |
|
242 | |||
224 | #endregion |
|
243 | #endregion | |
225 |
|
244 | |||
226 | #region IDisposable implementation |
|
245 | #region IDisposable implementation | |
227 |
|
246 | |||
|
247 | /// <summary> | |||
|
248 | /// Releases all resource used by the <see cref="Implab.Components.RunnableComponent"/> object. | |||
|
249 | /// </summary> | |||
|
250 | /// <remarks> | |||
|
251 | /// <para>Will not try to stop the component, it will just release all resources. | |||
|
252 | /// To cleanup the component gracefully use <see cref="Stop()"/> method.</para> | |||
|
253 | /// <para> | |||
|
254 | /// In normal cases the <see cref="Dispose()"/> method shouldn't be called, the call to the <see cref="Stop()"/> | |||
|
255 | /// method is sufficient to cleanup the component. Call <see cref="Dispose()"/> only to cleanup after errors, | |||
|
256 | /// especially if <see cref="Stop"/> method is failed. Using this method insted of <see cref="Stop()"/> may | |||
|
257 | /// lead to the data loss by the component. | |||
|
258 | /// </para></remarks> | |||
228 | public void Dispose() { |
|
259 | public void Dispose() { | |
229 | IPromise pending; |
|
260 | IPromise pending; | |
230 | lock (m_stateMachine) { |
|
261 | lock (m_stateMachine) { | |
231 | if (m_stateMachine.State == ExecutionState.Disposed) |
|
262 | if (m_stateMachine.State == ExecutionState.Disposed) | |
232 | return; |
|
263 | return; | |
233 |
|
264 | |||
234 | Move(Commands.Dispose); |
|
265 | Move(Commands.Dispose); | |
235 |
|
266 | |||
236 | GC.SuppressFinalize(this); |
|
267 | GC.SuppressFinalize(this); | |
237 |
|
268 | |||
238 | pending = m_pending; |
|
269 | pending = m_pending; | |
239 | m_pending = null; |
|
270 | m_pending = null; | |
240 | } |
|
271 | } | |
241 | if (pending != null) { |
|
272 | if (pending != null) { | |
242 | pending.Cancel(); |
|
273 | pending.Cancel(); | |
243 | pending.Timeout(DisposeTimeout).On( |
|
274 | pending.Timeout(DisposeTimeout).On( | |
244 | () => Dispose(true, null), |
|
275 | () => Dispose(true, null), | |
245 | err => Dispose(true, err), |
|
276 | err => Dispose(true, err), | |
246 | reason => Dispose(true, new OperationCanceledException("The operation is cancelled", reason)) |
|
277 | reason => Dispose(true, new OperationCanceledException("The operation is cancelled", reason)) | |
247 | ); |
|
278 | ); | |
248 | } else { |
|
279 | } else { | |
249 | Dispose(true, m_lastError); |
|
280 | Dispose(true, m_lastError); | |
250 | } |
|
281 | } | |
251 | } |
|
282 | } | |
252 |
|
283 | |||
253 | ~RunnableComponent() { |
|
284 | ~RunnableComponent() { | |
254 | Dispose(false, null); |
|
285 | Dispose(false, null); | |
255 | } |
|
286 | } | |
256 |
|
287 | |||
257 | #endregion |
|
288 | #endregion | |
258 |
|
289 | |||
259 | protected virtual void Dispose(bool disposing, Exception lastError) { |
|
290 | protected virtual void Dispose(bool disposing, Exception lastError) { | |
260 |
|
291 | |||
261 | } |
|
292 | } | |
262 |
|
293 | |||
263 | } |
|
294 | } | |
264 | } |
|
295 | } | |
265 |
|
296 |
@@ -1,276 +1,278 | |||||
1 | <?xml version="1.0" encoding="utf-8"?> |
|
1 | <?xml version="1.0" encoding="utf-8"?> | |
2 | <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> |
|
2 | <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> | |
3 | <PropertyGroup> |
|
3 | <PropertyGroup> | |
4 | <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> |
|
4 | <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> | |
5 | <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> |
|
5 | <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> | |
6 | <ProjectGuid>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</ProjectGuid> |
|
6 | <ProjectGuid>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</ProjectGuid> | |
7 | <OutputType>Library</OutputType> |
|
7 | <OutputType>Library</OutputType> | |
8 | <RootNamespace>Implab</RootNamespace> |
|
8 | <RootNamespace>Implab</RootNamespace> | |
9 | <AssemblyName>Implab</AssemblyName> |
|
9 | <AssemblyName>Implab</AssemblyName> | |
10 | <TargetFrameworkVersion>v4.5</TargetFrameworkVersion> |
|
10 | <TargetFrameworkVersion>v4.5</TargetFrameworkVersion> | |
11 | <ReleaseVersion>0.2</ReleaseVersion> |
|
11 | <ReleaseVersion>0.2</ReleaseVersion> | |
12 | <ProductVersion>8.0.30703</ProductVersion> |
|
12 | <ProductVersion>8.0.30703</ProductVersion> | |
13 | <SchemaVersion>2.0</SchemaVersion> |
|
13 | <SchemaVersion>2.0</SchemaVersion> | |
14 | </PropertyGroup> |
|
14 | </PropertyGroup> | |
15 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' "> |
|
15 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' "> | |
16 | <DebugSymbols>true</DebugSymbols> |
|
16 | <DebugSymbols>true</DebugSymbols> | |
17 | <DebugType>full</DebugType> |
|
17 | <DebugType>full</DebugType> | |
18 | <Optimize>false</Optimize> |
|
18 | <Optimize>false</Optimize> | |
19 | <OutputPath>bin\Debug</OutputPath> |
|
19 | <OutputPath>bin\Debug</OutputPath> | |
20 | <DefineConstants>TRACE;DEBUG;</DefineConstants> |
|
20 | <DefineConstants>TRACE;DEBUG;</DefineConstants> | |
21 | <ErrorReport>prompt</ErrorReport> |
|
21 | <ErrorReport>prompt</ErrorReport> | |
22 | <WarningLevel>4</WarningLevel> |
|
22 | <WarningLevel>4</WarningLevel> | |
23 | <ConsolePause>false</ConsolePause> |
|
23 | <ConsolePause>false</ConsolePause> | |
24 | <RunCodeAnalysis>true</RunCodeAnalysis> |
|
24 | <RunCodeAnalysis>true</RunCodeAnalysis> | |
25 | </PropertyGroup> |
|
25 | </PropertyGroup> | |
26 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' "> |
|
26 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' "> | |
27 | <DebugType>full</DebugType> |
|
27 | <DebugType>full</DebugType> | |
28 | <Optimize>true</Optimize> |
|
28 | <Optimize>true</Optimize> | |
29 | <OutputPath>bin\Release</OutputPath> |
|
29 | <OutputPath>bin\Release</OutputPath> | |
30 | <ErrorReport>prompt</ErrorReport> |
|
30 | <ErrorReport>prompt</ErrorReport> | |
31 | <WarningLevel>4</WarningLevel> |
|
31 | <WarningLevel>4</WarningLevel> | |
32 | <ConsolePause>false</ConsolePause> |
|
32 | <ConsolePause>false</ConsolePause> | |
33 | </PropertyGroup> |
|
33 | </PropertyGroup> | |
34 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug 4.5|AnyCPU' "> |
|
34 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug 4.5|AnyCPU' "> | |
35 | <DebugSymbols>true</DebugSymbols> |
|
35 | <DebugSymbols>true</DebugSymbols> | |
36 | <DebugType>full</DebugType> |
|
36 | <DebugType>full</DebugType> | |
37 | <Optimize>false</Optimize> |
|
37 | <Optimize>false</Optimize> | |
38 | <OutputPath>bin\Debug</OutputPath> |
|
38 | <OutputPath>bin\Debug</OutputPath> | |
39 | <DefineConstants>TRACE;DEBUG;NET_4_5</DefineConstants> |
|
39 | <DefineConstants>TRACE;DEBUG;NET_4_5</DefineConstants> | |
40 | <ErrorReport>prompt</ErrorReport> |
|
40 | <ErrorReport>prompt</ErrorReport> | |
41 | <WarningLevel>4</WarningLevel> |
|
41 | <WarningLevel>4</WarningLevel> | |
42 | <RunCodeAnalysis>true</RunCodeAnalysis> |
|
42 | <RunCodeAnalysis>true</RunCodeAnalysis> | |
43 | <ConsolePause>false</ConsolePause> |
|
43 | <ConsolePause>false</ConsolePause> | |
44 | </PropertyGroup> |
|
44 | </PropertyGroup> | |
45 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release 4.5|AnyCPU' "> |
|
45 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release 4.5|AnyCPU' "> | |
46 | <Optimize>true</Optimize> |
|
46 | <Optimize>true</Optimize> | |
47 | <OutputPath>bin\Release</OutputPath> |
|
47 | <OutputPath>bin\Release</OutputPath> | |
48 | <ErrorReport>prompt</ErrorReport> |
|
48 | <ErrorReport>prompt</ErrorReport> | |
49 | <WarningLevel>4</WarningLevel> |
|
49 | <WarningLevel>4</WarningLevel> | |
50 | <ConsolePause>false</ConsolePause> |
|
50 | <ConsolePause>false</ConsolePause> | |
51 | <DefineConstants>NET_4_5</DefineConstants> |
|
51 | <DefineConstants>NET_4_5</DefineConstants> | |
52 | </PropertyGroup> |
|
52 | </PropertyGroup> | |
53 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'DebugMono|AnyCPU' "> |
|
53 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'DebugMono|AnyCPU' "> | |
54 | <DebugSymbols>true</DebugSymbols> |
|
54 | <DebugSymbols>true</DebugSymbols> | |
55 | <DebugType>full</DebugType> |
|
55 | <DebugType>full</DebugType> | |
56 | <Optimize>false</Optimize> |
|
56 | <Optimize>false</Optimize> | |
57 | <OutputPath>bin\Debug</OutputPath> |
|
57 | <OutputPath>bin\Debug</OutputPath> | |
58 | <DefineConstants>TRACE;DEBUG;NET_4_5;MONO</DefineConstants> |
|
58 | <DefineConstants>TRACE;DEBUG;NET_4_5;MONO</DefineConstants> | |
59 | <ErrorReport>prompt</ErrorReport> |
|
59 | <ErrorReport>prompt</ErrorReport> | |
60 | <WarningLevel>4</WarningLevel> |
|
60 | <WarningLevel>4</WarningLevel> | |
61 | <RunCodeAnalysis>true</RunCodeAnalysis> |
|
61 | <RunCodeAnalysis>true</RunCodeAnalysis> | |
62 | <ConsolePause>false</ConsolePause> |
|
62 | <ConsolePause>false</ConsolePause> | |
63 | </PropertyGroup> |
|
63 | </PropertyGroup> | |
64 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'ReleaseMono|AnyCPU' "> |
|
64 | <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'ReleaseMono|AnyCPU' "> | |
65 | <Optimize>true</Optimize> |
|
65 | <Optimize>true</Optimize> | |
66 | <OutputPath>bin\Release</OutputPath> |
|
66 | <OutputPath>bin\Release</OutputPath> | |
67 | <DefineConstants>NET_4_5;MONO;</DefineConstants> |
|
67 | <DefineConstants>NET_4_5;MONO;</DefineConstants> | |
68 | <ErrorReport>prompt</ErrorReport> |
|
68 | <ErrorReport>prompt</ErrorReport> | |
69 | <WarningLevel>4</WarningLevel> |
|
69 | <WarningLevel>4</WarningLevel> | |
70 | <ConsolePause>false</ConsolePause> |
|
70 | <ConsolePause>false</ConsolePause> | |
71 | </PropertyGroup> |
|
71 | </PropertyGroup> | |
72 | <ItemGroup> |
|
72 | <ItemGroup> | |
73 | <Reference Include="System" /> |
|
73 | <Reference Include="System" /> | |
74 | <Reference Include="System.Xml" /> |
|
74 | <Reference Include="System.Xml" /> | |
75 | <Reference Include="mscorlib" /> |
|
75 | <Reference Include="mscorlib" /> | |
76 | </ItemGroup> |
|
76 | </ItemGroup> | |
77 | <ItemGroup> |
|
77 | <ItemGroup> | |
78 | <Compile Include="CustomEqualityComparer.cs" /> |
|
78 | <Compile Include="CustomEqualityComparer.cs" /> | |
79 | <Compile Include="Diagnostics\ConsoleTraceListener.cs" /> |
|
79 | <Compile Include="Diagnostics\ConsoleTraceListener.cs" /> | |
80 | <Compile Include="Diagnostics\LogChannel.cs" /> |
|
80 | <Compile Include="Diagnostics\LogChannel.cs" /> | |
81 | <Compile Include="Diagnostics\LogicalOperation.cs" /> |
|
81 | <Compile Include="Diagnostics\LogicalOperation.cs" /> | |
82 | <Compile Include="Diagnostics\TextFileListener.cs" /> |
|
82 | <Compile Include="Diagnostics\TextFileListener.cs" /> | |
83 | <Compile Include="Diagnostics\TraceLog.cs" /> |
|
83 | <Compile Include="Diagnostics\TraceLog.cs" /> | |
84 | <Compile Include="Diagnostics\TraceEvent.cs" /> |
|
84 | <Compile Include="Diagnostics\TraceEvent.cs" /> | |
85 | <Compile Include="Diagnostics\TraceEventType.cs" /> |
|
85 | <Compile Include="Diagnostics\TraceEventType.cs" /> | |
86 | <Compile Include="ICancellable.cs" /> |
|
86 | <Compile Include="ICancellable.cs" /> | |
87 | <Compile Include="IProgressHandler.cs" /> |
|
87 | <Compile Include="IProgressHandler.cs" /> | |
88 | <Compile Include="IProgressNotifier.cs" /> |
|
88 | <Compile Include="IProgressNotifier.cs" /> | |
89 | <Compile Include="IPromiseT.cs" /> |
|
89 | <Compile Include="IPromiseT.cs" /> | |
90 | <Compile Include="IPromise.cs" /> |
|
90 | <Compile Include="IPromise.cs" /> | |
91 | <Compile Include="IServiceLocator.cs" /> |
|
91 | <Compile Include="IServiceLocator.cs" /> | |
92 | <Compile Include="ITaskController.cs" /> |
|
92 | <Compile Include="ITaskController.cs" /> | |
93 | <Compile Include="Parallels\DispatchPool.cs" /> |
|
93 | <Compile Include="Parallels\DispatchPool.cs" /> | |
94 | <Compile Include="Parallels\ArrayTraits.cs" /> |
|
94 | <Compile Include="Parallels\ArrayTraits.cs" /> | |
95 | <Compile Include="Parallels\MTQueue.cs" /> |
|
95 | <Compile Include="Parallels\MTQueue.cs" /> | |
96 | <Compile Include="Parallels\WorkerPool.cs" /> |
|
96 | <Compile Include="Parallels\WorkerPool.cs" /> | |
97 | <Compile Include="ProgressInitEventArgs.cs" /> |
|
97 | <Compile Include="ProgressInitEventArgs.cs" /> | |
98 | <Compile Include="Properties\AssemblyInfo.cs" /> |
|
98 | <Compile Include="Properties\AssemblyInfo.cs" /> | |
99 | <Compile Include="Parallels\AsyncPool.cs" /> |
|
99 | <Compile Include="Parallels\AsyncPool.cs" /> | |
100 | <Compile Include="Safe.cs" /> |
|
100 | <Compile Include="Safe.cs" /> | |
101 | <Compile Include="ValueEventArgs.cs" /> |
|
101 | <Compile Include="ValueEventArgs.cs" /> | |
102 | <Compile Include="PromiseExtensions.cs" /> |
|
102 | <Compile Include="PromiseExtensions.cs" /> | |
103 | <Compile Include="SyncContextPromise.cs" /> |
|
103 | <Compile Include="SyncContextPromise.cs" /> | |
104 | <Compile Include="Diagnostics\OperationContext.cs" /> |
|
104 | <Compile Include="Diagnostics\OperationContext.cs" /> | |
105 | <Compile Include="Diagnostics\TraceContext.cs" /> |
|
105 | <Compile Include="Diagnostics\TraceContext.cs" /> | |
106 | <Compile Include="Diagnostics\LogEventArgs.cs" /> |
|
106 | <Compile Include="Diagnostics\LogEventArgs.cs" /> | |
107 | <Compile Include="Diagnostics\LogEventArgsT.cs" /> |
|
107 | <Compile Include="Diagnostics\LogEventArgsT.cs" /> | |
108 | <Compile Include="Diagnostics\Extensions.cs" /> |
|
108 | <Compile Include="Diagnostics\Extensions.cs" /> | |
109 | <Compile Include="PromiseEventType.cs" /> |
|
109 | <Compile Include="PromiseEventType.cs" /> | |
110 | <Compile Include="Parallels\AsyncQueue.cs" /> |
|
110 | <Compile Include="Parallels\AsyncQueue.cs" /> | |
111 | <Compile Include="PromiseT.cs" /> |
|
111 | <Compile Include="PromiseT.cs" /> | |
112 | <Compile Include="IDeferred.cs" /> |
|
112 | <Compile Include="IDeferred.cs" /> | |
113 | <Compile Include="IDeferredT.cs" /> |
|
113 | <Compile Include="IDeferredT.cs" /> | |
114 | <Compile Include="Promise.cs" /> |
|
114 | <Compile Include="Promise.cs" /> | |
115 | <Compile Include="PromiseTransientException.cs" /> |
|
115 | <Compile Include="PromiseTransientException.cs" /> | |
116 | <Compile Include="Parallels\Signal.cs" /> |
|
116 | <Compile Include="Parallels\Signal.cs" /> | |
117 | <Compile Include="Parallels\SharedLock.cs" /> |
|
117 | <Compile Include="Parallels\SharedLock.cs" /> | |
118 | <Compile Include="Diagnostics\ILogWriter.cs" /> |
|
118 | <Compile Include="Diagnostics\ILogWriter.cs" /> | |
119 | <Compile Include="Diagnostics\ListenerBase.cs" /> |
|
119 | <Compile Include="Diagnostics\ListenerBase.cs" /> | |
120 | <Compile Include="Parallels\BlockingQueue.cs" /> |
|
120 | <Compile Include="Parallels\BlockingQueue.cs" /> | |
121 | <Compile Include="AbstractEvent.cs" /> |
|
121 | <Compile Include="AbstractEvent.cs" /> | |
122 | <Compile Include="AbstractPromise.cs" /> |
|
122 | <Compile Include="AbstractPromise.cs" /> | |
123 | <Compile Include="AbstractPromiseT.cs" /> |
|
123 | <Compile Include="AbstractPromiseT.cs" /> | |
124 | <Compile Include="FuncTask.cs" /> |
|
124 | <Compile Include="FuncTask.cs" /> | |
125 | <Compile Include="FuncTaskBase.cs" /> |
|
125 | <Compile Include="FuncTaskBase.cs" /> | |
126 | <Compile Include="FuncTaskT.cs" /> |
|
126 | <Compile Include="FuncTaskT.cs" /> | |
127 | <Compile Include="ActionChainTaskBase.cs" /> |
|
127 | <Compile Include="ActionChainTaskBase.cs" /> | |
128 | <Compile Include="ActionChainTask.cs" /> |
|
128 | <Compile Include="ActionChainTask.cs" /> | |
129 | <Compile Include="ActionChainTaskT.cs" /> |
|
129 | <Compile Include="ActionChainTaskT.cs" /> | |
130 | <Compile Include="FuncChainTaskBase.cs" /> |
|
130 | <Compile Include="FuncChainTaskBase.cs" /> | |
131 | <Compile Include="FuncChainTask.cs" /> |
|
131 | <Compile Include="FuncChainTask.cs" /> | |
132 | <Compile Include="FuncChainTaskT.cs" /> |
|
132 | <Compile Include="FuncChainTaskT.cs" /> | |
133 | <Compile Include="ActionTaskBase.cs" /> |
|
133 | <Compile Include="ActionTaskBase.cs" /> | |
134 | <Compile Include="ActionTask.cs" /> |
|
134 | <Compile Include="ActionTask.cs" /> | |
135 | <Compile Include="ActionTaskT.cs" /> |
|
135 | <Compile Include="ActionTaskT.cs" /> | |
136 | <Compile Include="ICancellationToken.cs" /> |
|
136 | <Compile Include="ICancellationToken.cs" /> | |
137 | <Compile Include="SuccessPromise.cs" /> |
|
137 | <Compile Include="SuccessPromise.cs" /> | |
138 | <Compile Include="SuccessPromiseT.cs" /> |
|
138 | <Compile Include="SuccessPromiseT.cs" /> | |
139 | <Compile Include="PromiseAwaiterT.cs" /> |
|
139 | <Compile Include="PromiseAwaiterT.cs" /> | |
140 | <Compile Include="PromiseAwaiter.cs" /> |
|
140 | <Compile Include="PromiseAwaiter.cs" /> | |
141 | <Compile Include="Components\ComponentContainer.cs" /> |
|
141 | <Compile Include="Components\ComponentContainer.cs" /> | |
142 | <Compile Include="Components\Disposable.cs" /> |
|
142 | <Compile Include="Components\Disposable.cs" /> | |
143 | <Compile Include="Components\DisposablePool.cs" /> |
|
143 | <Compile Include="Components\DisposablePool.cs" /> | |
144 | <Compile Include="Components\ObjectPool.cs" /> |
|
144 | <Compile Include="Components\ObjectPool.cs" /> | |
145 | <Compile Include="Components\ServiceLocator.cs" /> |
|
145 | <Compile Include="Components\ServiceLocator.cs" /> | |
146 | <Compile Include="Components\IInitializable.cs" /> |
|
146 | <Compile Include="Components\IInitializable.cs" /> | |
147 | <Compile Include="TaskController.cs" /> |
|
147 | <Compile Include="TaskController.cs" /> | |
148 | <Compile Include="Components\App.cs" /> |
|
148 | <Compile Include="Components\App.cs" /> | |
149 | <Compile Include="Components\IRunnable.cs" /> |
|
149 | <Compile Include="Components\IRunnable.cs" /> | |
150 | <Compile Include="Components\ExecutionState.cs" /> |
|
150 | <Compile Include="Components\ExecutionState.cs" /> | |
151 | <Compile Include="Components\RunnableComponent.cs" /> |
|
151 | <Compile Include="Components\RunnableComponent.cs" /> | |
152 | <Compile Include="Components\IFactory.cs" /> |
|
152 | <Compile Include="Components\IFactory.cs" /> | |
153 | <Compile Include="Automaton\IAlphabet.cs" /> |
|
153 | <Compile Include="Automaton\IAlphabet.cs" /> | |
154 | <Compile Include="Automaton\ParserException.cs" /> |
|
154 | <Compile Include="Automaton\ParserException.cs" /> | |
155 | <Compile Include="Automaton\IndexedAlphabetBase.cs" /> |
|
155 | <Compile Include="Automaton\IndexedAlphabetBase.cs" /> | |
156 | <Compile Include="Automaton\IAlphabetBuilder.cs" /> |
|
156 | <Compile Include="Automaton\IAlphabetBuilder.cs" /> | |
157 | <Compile Include="Automaton\RegularExpressions\AltToken.cs" /> |
|
157 | <Compile Include="Automaton\RegularExpressions\AltToken.cs" /> | |
158 | <Compile Include="Automaton\RegularExpressions\BinaryToken.cs" /> |
|
158 | <Compile Include="Automaton\RegularExpressions\BinaryToken.cs" /> | |
159 | <Compile Include="Automaton\RegularExpressions\CatToken.cs" /> |
|
159 | <Compile Include="Automaton\RegularExpressions\CatToken.cs" /> | |
160 | <Compile Include="Automaton\RegularExpressions\StarToken.cs" /> |
|
160 | <Compile Include="Automaton\RegularExpressions\StarToken.cs" /> | |
161 | <Compile Include="Automaton\RegularExpressions\SymbolToken.cs" /> |
|
161 | <Compile Include="Automaton\RegularExpressions\SymbolToken.cs" /> | |
162 | <Compile Include="Automaton\RegularExpressions\EmptyToken.cs" /> |
|
162 | <Compile Include="Automaton\RegularExpressions\EmptyToken.cs" /> | |
163 | <Compile Include="Automaton\RegularExpressions\Token.cs" /> |
|
163 | <Compile Include="Automaton\RegularExpressions\Token.cs" /> | |
164 | <Compile Include="Automaton\RegularExpressions\IVisitor.cs" /> |
|
164 | <Compile Include="Automaton\RegularExpressions\IVisitor.cs" /> | |
165 | <Compile Include="Automaton\AutomatonTransition.cs" /> |
|
165 | <Compile Include="Automaton\AutomatonTransition.cs" /> | |
166 | <Compile Include="Formats\JSON\JSONElementContext.cs" /> |
|
166 | <Compile Include="Formats\JSON\JSONElementContext.cs" /> | |
167 | <Compile Include="Formats\JSON\JSONElementType.cs" /> |
|
167 | <Compile Include="Formats\JSON\JSONElementType.cs" /> | |
168 | <Compile Include="Formats\JSON\JSONGrammar.cs" /> |
|
168 | <Compile Include="Formats\JSON\JSONGrammar.cs" /> | |
169 | <Compile Include="Formats\JSON\JSONParser.cs" /> |
|
169 | <Compile Include="Formats\JSON\JSONParser.cs" /> | |
170 | <Compile Include="Formats\JSON\JSONScanner.cs" /> |
|
170 | <Compile Include="Formats\JSON\JSONScanner.cs" /> | |
171 | <Compile Include="Formats\JSON\JsonTokenType.cs" /> |
|
171 | <Compile Include="Formats\JSON\JsonTokenType.cs" /> | |
172 | <Compile Include="Formats\JSON\JSONWriter.cs" /> |
|
172 | <Compile Include="Formats\JSON\JSONWriter.cs" /> | |
173 | <Compile Include="Formats\JSON\JSONXmlReader.cs" /> |
|
173 | <Compile Include="Formats\JSON\JSONXmlReader.cs" /> | |
174 | <Compile Include="Formats\JSON\JSONXmlReaderOptions.cs" /> |
|
174 | <Compile Include="Formats\JSON\JSONXmlReaderOptions.cs" /> | |
175 | <Compile Include="Formats\JSON\StringTranslator.cs" /> |
|
175 | <Compile Include="Formats\JSON\StringTranslator.cs" /> | |
176 | <Compile Include="Automaton\MapAlphabet.cs" /> |
|
176 | <Compile Include="Automaton\MapAlphabet.cs" /> | |
177 | <Compile Include="Formats\CharAlphabet.cs" /> |
|
177 | <Compile Include="Formats\CharAlphabet.cs" /> | |
178 | <Compile Include="Formats\ByteAlphabet.cs" /> |
|
178 | <Compile Include="Formats\ByteAlphabet.cs" /> | |
179 | <Compile Include="Automaton\IDFATable.cs" /> |
|
179 | <Compile Include="Automaton\IDFATable.cs" /> | |
180 | <Compile Include="Automaton\IDFATableBuilder.cs" /> |
|
180 | <Compile Include="Automaton\IDFATableBuilder.cs" /> | |
181 | <Compile Include="Automaton\DFATable.cs" /> |
|
181 | <Compile Include="Automaton\DFATable.cs" /> | |
182 | <Compile Include="Automaton\RegularExpressions\RegularExpressionVisitor.cs" /> |
|
182 | <Compile Include="Automaton\RegularExpressions\RegularExpressionVisitor.cs" /> | |
183 | <Compile Include="Automaton\RegularExpressions\ITaggedDFABuilder.cs" /> |
|
183 | <Compile Include="Automaton\RegularExpressions\ITaggedDFABuilder.cs" /> | |
184 | <Compile Include="Formats\TextScanner.cs" /> |
|
184 | <Compile Include="Formats\TextScanner.cs" /> | |
185 | <Compile Include="Formats\StringScanner.cs" /> |
|
185 | <Compile Include="Formats\StringScanner.cs" /> | |
186 | <Compile Include="Formats\ReaderScanner.cs" /> |
|
186 | <Compile Include="Formats\ReaderScanner.cs" /> | |
187 | <Compile Include="Formats\ScannerContext.cs" /> |
|
187 | <Compile Include="Formats\ScannerContext.cs" /> | |
188 | <Compile Include="Formats\Grammar.cs" /> |
|
188 | <Compile Include="Formats\Grammar.cs" /> | |
189 | <Compile Include="Automaton\RegularExpressions\EndTokenT.cs" /> |
|
189 | <Compile Include="Automaton\RegularExpressions\EndTokenT.cs" /> | |
190 | <Compile Include="Automaton\RegularExpressions\EndToken.cs" /> |
|
190 | <Compile Include="Automaton\RegularExpressions\EndToken.cs" /> | |
191 | <Compile Include="Automaton\RegularExpressions\RegularExpressionVisitorT.cs" /> |
|
191 | <Compile Include="Automaton\RegularExpressions\RegularExpressionVisitorT.cs" /> | |
192 | <Compile Include="Automaton\AutomatonConst.cs" /> |
|
192 | <Compile Include="Automaton\AutomatonConst.cs" /> | |
193 | <Compile Include="Automaton\RegularExpressions\RegularDFA.cs" /> |
|
193 | <Compile Include="Automaton\RegularExpressions\RegularDFA.cs" /> | |
194 | <Compile Include="Components\LazyAndWeak.cs" /> |
|
194 | <Compile Include="Components\LazyAndWeak.cs" /> | |
195 | <Compile Include="AbstractTask.cs" /> |
|
195 | <Compile Include="AbstractTask.cs" /> | |
196 | <Compile Include="AbstractTaskT.cs" /> |
|
196 | <Compile Include="AbstractTaskT.cs" /> | |
197 |
<Compile Include=" |
|
197 | <Compile Include="FailedPromise.cs" /> | |
|
198 | <Compile Include="FailedPromiseT.cs" /> | |||
|
199 | <Compile Include="Components\PollingComponent.cs" /> | |||
198 | </ItemGroup> |
|
200 | </ItemGroup> | |
199 | <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" /> |
|
201 | <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" /> | |
200 | <ItemGroup /> |
|
202 | <ItemGroup /> | |
201 | <ProjectExtensions> |
|
203 | <ProjectExtensions> | |
202 | <MonoDevelop> |
|
204 | <MonoDevelop> | |
203 | <Properties> |
|
205 | <Properties> | |
204 | <Policies> |
|
206 | <Policies> | |
205 | <CSharpFormattingPolicy IndentSwitchBody="True" NamespaceBraceStyle="EndOfLine" ClassBraceStyle="EndOfLine" InterfaceBraceStyle="EndOfLine" StructBraceStyle="EndOfLine" EnumBraceStyle="EndOfLine" MethodBraceStyle="EndOfLine" ConstructorBraceStyle="EndOfLine" DestructorBraceStyle="EndOfLine" BeforeMethodDeclarationParentheses="False" BeforeMethodCallParentheses="False" BeforeConstructorDeclarationParentheses="False" NewLineBeforeConstructorInitializerColon="NewLine" NewLineAfterConstructorInitializerColon="SameLine" BeforeIndexerDeclarationBracket="False" BeforeDelegateDeclarationParentheses="False" NewParentheses="False" SpacesBeforeBrackets="False" inheritsSet="Mono" inheritsScope="text/x-csharp" scope="text/x-csharp" /> |
|
207 | <CSharpFormattingPolicy IndentSwitchBody="True" NamespaceBraceStyle="EndOfLine" ClassBraceStyle="EndOfLine" InterfaceBraceStyle="EndOfLine" StructBraceStyle="EndOfLine" EnumBraceStyle="EndOfLine" MethodBraceStyle="EndOfLine" ConstructorBraceStyle="EndOfLine" DestructorBraceStyle="EndOfLine" BeforeMethodDeclarationParentheses="False" BeforeMethodCallParentheses="False" BeforeConstructorDeclarationParentheses="False" NewLineBeforeConstructorInitializerColon="NewLine" NewLineAfterConstructorInitializerColon="SameLine" BeforeIndexerDeclarationBracket="False" BeforeDelegateDeclarationParentheses="False" NewParentheses="False" SpacesBeforeBrackets="False" inheritsSet="Mono" inheritsScope="text/x-csharp" scope="text/x-csharp" /> | |
206 | <TextStylePolicy FileWidth="120" EolMarker="Unix" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="text/x-csharp" /> |
|
208 | <TextStylePolicy FileWidth="120" EolMarker="Unix" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="text/x-csharp" /> | |
207 | <DotNetNamingPolicy DirectoryNamespaceAssociation="PrefixedHierarchical" ResourceNamePolicy="MSBuild" /> |
|
209 | <DotNetNamingPolicy DirectoryNamespaceAssociation="PrefixedHierarchical" ResourceNamePolicy="MSBuild" /> | |
208 | <TextStylePolicy FileWidth="120" TabsToSpaces="False" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="application/xml" /> |
|
210 | <TextStylePolicy FileWidth="120" TabsToSpaces="False" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="application/xml" /> | |
209 | <XmlFormattingPolicy inheritsSet="Mono" inheritsScope="application/xml" scope="application/xml" /> |
|
211 | <XmlFormattingPolicy inheritsSet="Mono" inheritsScope="application/xml" scope="application/xml" /> | |
210 | <TextStylePolicy FileWidth="120" TabsToSpaces="False" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="text/plain" /> |
|
212 | <TextStylePolicy FileWidth="120" TabsToSpaces="False" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="text/plain" /> | |
211 | <NameConventionPolicy> |
|
213 | <NameConventionPolicy> | |
212 | <Rules> |
|
214 | <Rules> | |
213 | <NamingRule Name="Namespaces" AffectedEntity="Namespace" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> |
|
215 | <NamingRule Name="Namespaces" AffectedEntity="Namespace" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> | |
214 | <NamingRule Name="Types" AffectedEntity="Class, Struct, Enum, Delegate" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> |
|
216 | <NamingRule Name="Types" AffectedEntity="Class, Struct, Enum, Delegate" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> | |
215 | <NamingRule Name="Interfaces" AffectedEntity="Interface" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True"> |
|
217 | <NamingRule Name="Interfaces" AffectedEntity="Interface" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True"> | |
216 | <RequiredPrefixes> |
|
218 | <RequiredPrefixes> | |
217 | <String>I</String> |
|
219 | <String>I</String> | |
218 | </RequiredPrefixes> |
|
220 | </RequiredPrefixes> | |
219 | </NamingRule> |
|
221 | </NamingRule> | |
220 | <NamingRule Name="Attributes" AffectedEntity="CustomAttributes" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True"> |
|
222 | <NamingRule Name="Attributes" AffectedEntity="CustomAttributes" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True"> | |
221 | <RequiredSuffixes> |
|
223 | <RequiredSuffixes> | |
222 | <String>Attribute</String> |
|
224 | <String>Attribute</String> | |
223 | </RequiredSuffixes> |
|
225 | </RequiredSuffixes> | |
224 | </NamingRule> |
|
226 | </NamingRule> | |
225 | <NamingRule Name="Event Arguments" AffectedEntity="CustomEventArgs" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True"> |
|
227 | <NamingRule Name="Event Arguments" AffectedEntity="CustomEventArgs" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True"> | |
226 | <RequiredSuffixes> |
|
228 | <RequiredSuffixes> | |
227 | <String>EventArgs</String> |
|
229 | <String>EventArgs</String> | |
228 | </RequiredSuffixes> |
|
230 | </RequiredSuffixes> | |
229 | </NamingRule> |
|
231 | </NamingRule> | |
230 | <NamingRule Name="Exceptions" AffectedEntity="CustomExceptions" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True"> |
|
232 | <NamingRule Name="Exceptions" AffectedEntity="CustomExceptions" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True"> | |
231 | <RequiredSuffixes> |
|
233 | <RequiredSuffixes> | |
232 | <String>Exception</String> |
|
234 | <String>Exception</String> | |
233 | </RequiredSuffixes> |
|
235 | </RequiredSuffixes> | |
234 | </NamingRule> |
|
236 | </NamingRule> | |
235 | <NamingRule Name="Methods" AffectedEntity="Methods" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> |
|
237 | <NamingRule Name="Methods" AffectedEntity="Methods" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> | |
236 | <NamingRule Name="Static Readonly Fields" AffectedEntity="ReadonlyField" VisibilityMask="Internal, Protected, Public" NamingStyle="CamelCase" IncludeInstanceMembers="False" IncludeStaticEntities="True" /> |
|
238 | <NamingRule Name="Static Readonly Fields" AffectedEntity="ReadonlyField" VisibilityMask="Internal, Protected, Public" NamingStyle="CamelCase" IncludeInstanceMembers="False" IncludeStaticEntities="True" /> | |
237 | <NamingRule Name="Fields (Non Private)" AffectedEntity="Field" VisibilityMask="Internal, Public" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> |
|
239 | <NamingRule Name="Fields (Non Private)" AffectedEntity="Field" VisibilityMask="Internal, Public" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> | |
238 | <NamingRule Name="ReadOnly Fields (Non Private)" AffectedEntity="ReadonlyField" VisibilityMask="Internal, Public" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False" /> |
|
240 | <NamingRule Name="ReadOnly Fields (Non Private)" AffectedEntity="ReadonlyField" VisibilityMask="Internal, Public" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False" /> | |
239 | <NamingRule Name="Fields (Private)" AffectedEntity="Field, ReadonlyField" VisibilityMask="Private, Protected" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False"> |
|
241 | <NamingRule Name="Fields (Private)" AffectedEntity="Field, ReadonlyField" VisibilityMask="Private, Protected" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False"> | |
240 | <RequiredPrefixes> |
|
242 | <RequiredPrefixes> | |
241 | <String>m_</String> |
|
243 | <String>m_</String> | |
242 | </RequiredPrefixes> |
|
244 | </RequiredPrefixes> | |
243 | </NamingRule> |
|
245 | </NamingRule> | |
244 | <NamingRule Name="Static Fields (Private)" AffectedEntity="Field" VisibilityMask="Private" NamingStyle="CamelCase" IncludeInstanceMembers="False" IncludeStaticEntities="True"> |
|
246 | <NamingRule Name="Static Fields (Private)" AffectedEntity="Field" VisibilityMask="Private" NamingStyle="CamelCase" IncludeInstanceMembers="False" IncludeStaticEntities="True"> | |
245 | <RequiredPrefixes> |
|
247 | <RequiredPrefixes> | |
246 | <String>_</String> |
|
248 | <String>_</String> | |
247 | </RequiredPrefixes> |
|
249 | </RequiredPrefixes> | |
248 | </NamingRule> |
|
250 | </NamingRule> | |
249 | <NamingRule Name="ReadOnly Fields (Private)" AffectedEntity="ReadonlyField" VisibilityMask="Private, Protected" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False"> |
|
251 | <NamingRule Name="ReadOnly Fields (Private)" AffectedEntity="ReadonlyField" VisibilityMask="Private, Protected" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False"> | |
250 | <RequiredPrefixes> |
|
252 | <RequiredPrefixes> | |
251 | <String>m_</String> |
|
253 | <String>m_</String> | |
252 | </RequiredPrefixes> |
|
254 | </RequiredPrefixes> | |
253 | </NamingRule> |
|
255 | </NamingRule> | |
254 | <NamingRule Name="Constant Fields" AffectedEntity="ConstantField" VisibilityMask="VisibilityMask" NamingStyle="AllUpper" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> |
|
256 | <NamingRule Name="Constant Fields" AffectedEntity="ConstantField" VisibilityMask="VisibilityMask" NamingStyle="AllUpper" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> | |
255 | <NamingRule Name="Properties" AffectedEntity="Property" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> |
|
257 | <NamingRule Name="Properties" AffectedEntity="Property" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> | |
256 | <NamingRule Name="Events" AffectedEntity="Event" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> |
|
258 | <NamingRule Name="Events" AffectedEntity="Event" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> | |
257 | <NamingRule Name="Enum Members" AffectedEntity="EnumMember" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> |
|
259 | <NamingRule Name="Enum Members" AffectedEntity="EnumMember" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> | |
258 | <NamingRule Name="Parameters" AffectedEntity="Parameter, LocalVariable" VisibilityMask="VisibilityMask" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> |
|
260 | <NamingRule Name="Parameters" AffectedEntity="Parameter, LocalVariable" VisibilityMask="VisibilityMask" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" /> | |
259 | <NamingRule Name="Type Parameters" AffectedEntity="TypeParameter" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True"> |
|
261 | <NamingRule Name="Type Parameters" AffectedEntity="TypeParameter" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True"> | |
260 | <RequiredPrefixes> |
|
262 | <RequiredPrefixes> | |
261 | <String>T</String> |
|
263 | <String>T</String> | |
262 | </RequiredPrefixes> |
|
264 | </RequiredPrefixes> | |
263 | </NamingRule> |
|
265 | </NamingRule> | |
264 | </Rules> |
|
266 | </Rules> | |
265 | </NameConventionPolicy> |
|
267 | </NameConventionPolicy> | |
266 | </Policies> |
|
268 | </Policies> | |
267 | </Properties> |
|
269 | </Properties> | |
268 | </MonoDevelop> |
|
270 | </MonoDevelop> | |
269 | </ProjectExtensions> |
|
271 | </ProjectExtensions> | |
270 | <ItemGroup> |
|
272 | <ItemGroup> | |
271 | <Folder Include="Components\" /> |
|
273 | <Folder Include="Components\" /> | |
272 | <Folder Include="Automaton\RegularExpressions\" /> |
|
274 | <Folder Include="Automaton\RegularExpressions\" /> | |
273 | <Folder Include="Formats\" /> |
|
275 | <Folder Include="Formats\" /> | |
274 | <Folder Include="Formats\JSON\" /> |
|
276 | <Folder Include="Formats\JSON\" /> | |
275 | </ItemGroup> |
|
277 | </ItemGroup> | |
276 | </Project> No newline at end of file |
|
278 | </Project> |
@@ -1,61 +1,59 | |||||
1 | using System; |
|
1 | using System; | |
2 | using System.Diagnostics; |
|
2 | using System.Diagnostics; | |
3 | using Implab.Parallels; |
|
3 | using Implab.Parallels; | |
4 |
|
4 | |||
5 | namespace Implab { |
|
5 | namespace Implab { | |
6 |
|
6 | |||
7 | /// <summary> |
|
7 | /// <summary> | |
8 | /// Класс для асинхронного получения результатов. Так называемое "обещание". |
|
8 | /// Класс для асинхронного получения результатов. Так называемое "обещание". | |
9 | /// </summary> |
|
9 | /// </summary> | |
10 | /// <typeparam name="T">Тип получаемого результата</typeparam> |
|
10 | /// <typeparam name="T">Тип получаемого результата</typeparam> | |
11 | /// <remarks> |
|
11 | /// <remarks> | |
12 | /// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции, |
|
12 | /// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции, | |
13 | /// клиент получив такое обещание может установить ряд обратных вызово для получения |
|
13 | /// клиент получив такое обещание может установить ряд обратных вызово для получения | |
14 | /// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para> |
|
14 | /// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para> | |
15 | /// <para> |
|
15 | /// <para> | |
16 | /// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на |
|
16 | /// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на | |
17 | /// данные события клиент должен использовать методы <c>Then</c>. |
|
17 | /// данные события клиент должен использовать методы <c>Then</c>. | |
18 | /// </para> |
|
18 | /// </para> | |
19 | /// <para> |
|
19 | /// <para> | |
20 | /// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой), |
|
20 | /// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой), | |
21 | /// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о |
|
21 | /// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о | |
22 | /// выполнении обещания. |
|
22 | /// выполнении обещания. | |
23 | /// </para> |
|
23 | /// </para> | |
24 | /// <para> |
|
24 | /// <para> | |
25 | /// Если сервер успел выполнить обещание еще до того, как клиент на него подписался, |
|
25 | /// Если сервер успел выполнить обещание еще до того, как клиент на него подписался, | |
26 | /// то в момент подписки клиента будут вызваны соответсвующие события в синхронном |
|
26 | /// то в момент подписки клиента будут вызваны соответсвующие события в синхронном | |
27 | /// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в |
|
27 | /// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в | |
28 | /// список в порядке подписания и в этом же порядке они будут вызваны при выполнении |
|
28 | /// список в порядке подписания и в этом же порядке они будут вызваны при выполнении | |
29 | /// обещания. |
|
29 | /// обещания. | |
30 | /// </para> |
|
30 | /// </para> | |
31 | /// <para> |
|
31 | /// <para> | |
32 | /// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать |
|
32 | /// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать | |
33 | /// связанные асинхронные операции, которые также возвращают обещания. Для этого следует |
|
33 | /// связанные асинхронные операции, которые также возвращают обещания. Для этого следует | |
34 | /// использовать соответствующую форму методе <c>Then</c>. |
|
34 | /// использовать соответствующую форму методе <c>Then</c>. | |
35 | /// </para> |
|
35 | /// </para> | |
36 | /// <para> |
|
36 | /// <para> | |
37 | /// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать |
|
37 | /// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать | |
38 | /// только инициатор обещания иначе могут возникнуть противоречия. |
|
38 | /// только инициатор обещания иначе могут возникнуть противоречия. | |
39 | /// </para> |
|
39 | /// </para> | |
40 | /// </remarks> |
|
40 | /// </remarks> | |
41 | public class Promise<T> : AbstractPromise<T>, IDeferred<T> { |
|
41 | public class Promise<T> : AbstractPromise<T>, IDeferred<T> { | |
42 |
|
42 | |||
43 | public static IPromise<T> FromResult(T value) { |
|
43 | public static IPromise<T> FromResult(T value) { | |
44 | return new SuccessPromise<T>(value); |
|
44 | return new SuccessPromise<T>(value); | |
45 | } |
|
45 | } | |
46 |
|
46 | |||
47 | public static IPromise<T> FromException(Exception error) { |
|
47 | public static IPromise<T> FromException(Exception error) { | |
48 |
|
|
48 | return new FailedPromise<T>(error); | |
49 | p.Reject(error); |
|
|||
50 | return p; |
|
|||
51 | } |
|
49 | } | |
52 |
|
50 | |||
53 | public virtual void Resolve(T value) { |
|
51 | public virtual void Resolve(T value) { | |
54 | SetResult(value); |
|
52 | SetResult(value); | |
55 | } |
|
53 | } | |
56 |
|
54 | |||
57 | public void Reject(Exception error) { |
|
55 | public void Reject(Exception error) { | |
58 | SetError(error); |
|
56 | SetError(error); | |
59 | } |
|
57 | } | |
60 | } |
|
58 | } | |
61 | } |
|
59 | } |
@@ -1,128 +1,114 | |||||
1 | using System; |
|
1 | using System; | |
2 | using System.Collections.Generic; |
|
2 | using System.Collections.Generic; | |
3 | using System.Linq; |
|
3 | using System.Linq; | |
4 | using System.Text; |
|
4 | using System.Text; | |
5 | using System.Text.RegularExpressions; |
|
5 | using System.Text.RegularExpressions; | |
6 | using System.Diagnostics; |
|
6 | using System.Diagnostics; | |
7 |
|
7 | |||
8 | namespace Implab |
|
8 | namespace Implab | |
9 | { |
|
9 | { | |
10 | public static class Safe |
|
10 | public static class Safe | |
11 | { |
|
11 | { | |
12 | public static void ArgumentAssert(bool condition, string paramName) { |
|
12 | public static void ArgumentAssert(bool condition, string paramName) { | |
13 | if (!condition) |
|
13 | if (!condition) | |
14 | throw new ArgumentException("The parameter is invalid", paramName); |
|
14 | throw new ArgumentException("The parameter is invalid", paramName); | |
15 | } |
|
15 | } | |
16 |
|
16 | |||
17 | public static void ArgumentMatch(string value, string paramName, Regex rx) { |
|
17 | public static void ArgumentMatch(string value, string paramName, Regex rx) { | |
18 | if (rx == null) |
|
18 | if (rx == null) | |
19 | throw new ArgumentNullException("rx"); |
|
19 | throw new ArgumentNullException("rx"); | |
20 | if (!rx.IsMatch(value)) |
|
20 | if (!rx.IsMatch(value)) | |
21 | throw new ArgumentException(String.Format("The prameter value must match {0}", rx), paramName); |
|
21 | throw new ArgumentException(String.Format("The prameter value must match {0}", rx), paramName); | |
22 | } |
|
22 | } | |
23 |
|
23 | |||
24 | public static void ArgumentNotEmpty(string value, string paramName) { |
|
24 | public static void ArgumentNotEmpty(string value, string paramName) { | |
25 | if (String.IsNullOrEmpty(value)) |
|
25 | if (String.IsNullOrEmpty(value)) | |
26 | throw new ArgumentException("The parameter can't be empty", paramName); |
|
26 | throw new ArgumentException("The parameter can't be empty", paramName); | |
27 | } |
|
27 | } | |
28 |
|
28 | |||
29 | public static void ArgumentNotEmpty<T>(T[] value, string paramName) { |
|
29 | public static void ArgumentNotEmpty<T>(T[] value, string paramName) { | |
30 | if (value == null || value.Length == 0) |
|
30 | if (value == null || value.Length == 0) | |
31 | throw new ArgumentException("The array must be not emty", paramName); |
|
31 | throw new ArgumentException("The array must be not emty", paramName); | |
32 | } |
|
32 | } | |
33 |
|
33 | |||
34 | public static void ArgumentNotNull(object value, string paramName) { |
|
34 | public static void ArgumentNotNull(object value, string paramName) { | |
35 | if (value == null) |
|
35 | if (value == null) | |
36 | throw new ArgumentNullException(paramName); |
|
36 | throw new ArgumentNullException(paramName); | |
37 | } |
|
37 | } | |
38 |
|
38 | |||
39 | public static void ArgumentInRange(int value, int min, int max, string paramName) { |
|
39 | public static void ArgumentInRange(int value, int min, int max, string paramName) { | |
40 | if (value < min || value > max) |
|
40 | if (value < min || value > max) | |
41 | throw new ArgumentOutOfRangeException(paramName); |
|
41 | throw new ArgumentOutOfRangeException(paramName); | |
42 | } |
|
42 | } | |
43 |
|
43 | |||
44 | public static void ArgumentOfType(object value, Type type, string paramName) { |
|
44 | public static void ArgumentOfType(object value, Type type, string paramName) { | |
45 | if (!type.IsInstanceOfType(value)) |
|
45 | if (!type.IsInstanceOfType(value)) | |
46 | throw new ArgumentException(String.Format("The parameter must be of type {0}", type), paramName); |
|
46 | throw new ArgumentException(String.Format("The parameter must be of type {0}", type), paramName); | |
47 | } |
|
47 | } | |
48 |
|
48 | |||
49 | public static void Dispose(params IDisposable[] objects) { |
|
49 | public static void Dispose(params IDisposable[] objects) { | |
50 | foreach (var d in objects) |
|
50 | foreach (var d in objects) | |
51 | if (d != null) |
|
51 | if (d != null) | |
52 | d.Dispose(); |
|
52 | d.Dispose(); | |
53 | } |
|
53 | } | |
54 |
|
54 | |||
55 | public static void Dispose(params object[] objects) { |
|
55 | public static void Dispose(params object[] objects) { | |
56 | foreach (var obj in objects) { |
|
56 | foreach (var obj in objects) { | |
57 | var d = obj as IDisposable; |
|
57 | var d = obj as IDisposable; | |
58 | if (d != null) |
|
58 | if (d != null) | |
59 | d.Dispose(); |
|
59 | d.Dispose(); | |
60 | } |
|
60 | } | |
61 | } |
|
61 | } | |
62 |
|
62 | |||
63 | public static void Dispose(object obj) { |
|
63 | public static void Dispose(object obj) { | |
64 | var d = obj as IDisposable; |
|
64 | var d = obj as IDisposable; | |
65 | if (d != null) |
|
65 | if (d != null) | |
66 | d.Dispose(); |
|
66 | d.Dispose(); | |
67 | } |
|
67 | } | |
68 |
|
68 | |||
69 | [DebuggerStepThrough] |
|
69 | [DebuggerStepThrough] | |
70 |
public static IPromise<T> |
|
70 | public static IPromise<T> Run<T>(Func<T> action) { | |
71 | ArgumentNotNull(action, "action"); |
|
|||
72 |
|
||||
73 | var p = new Promise<T>(); |
|
|||
74 | try { |
|
|||
75 | p.Resolve(action()); |
|
|||
76 | } catch (Exception err) { |
|
|||
77 | p.Reject(err); |
|
|||
78 | } |
|
|||
79 |
|
||||
80 | return p; |
|
|||
81 | } |
|
|||
82 |
|
||||
83 | [DebuggerStepThrough] |
|
|||
84 | public static IPromise WrapPromise(Action action) { |
|
|||
85 | ArgumentNotNull(action, "action"); |
|
|||
86 |
|
||||
87 | var p = new Promise(); |
|
|||
88 | try { |
|
|||
89 | action(); |
|
|||
90 | p.Resolve(); |
|
|||
91 | } catch (Exception err) { |
|
|||
92 | p.Reject(err); |
|
|||
93 | } |
|
|||
94 |
|
||||
95 | return p; |
|
|||
96 | } |
|
|||
97 |
|
||||
98 | [DebuggerStepThrough] |
|
|||
99 | public static IPromise InvokePromise(Func<IPromise> action) { |
|
|||
100 | ArgumentNotNull(action, "action"); |
|
71 | ArgumentNotNull(action, "action"); | |
101 |
|
72 | |||
102 | try { |
|
73 | try { | |
103 |
|
|
74 | return Promise<T>.FromResult(action()); | |
104 | if (p == null) { |
|
|||
105 | var d = new Promise(); |
|
|||
106 | d.Reject(new Exception("The action returned null")); |
|
|||
107 | p = d; |
|
|||
108 | } |
|
|||
109 | return p; |
|
|||
110 | } catch (Exception err) { |
|
75 | } catch (Exception err) { | |
111 |
|
|
76 | return Promise<T>.FromException(err); | |
112 | p.Reject(err); |
|
|||
113 | return p; |
|
|||
114 | } |
|
77 | } | |
115 | } |
|
78 | } | |
116 |
|
79 | |||
117 | [DebuggerStepThrough] |
|
80 | [DebuggerStepThrough] | |
118 |
public static IPromise |
|
81 | public static IPromise Run(Action action) { | |
|
82 | ArgumentNotNull(action, "action"); | |||
|
83 | ||||
|
84 | try { | |||
|
85 | action(); | |||
|
86 | return Promise.SUCCESS; | |||
|
87 | } catch (Exception err) { | |||
|
88 | return new FailedPromise(err); | |||
|
89 | } | |||
|
90 | } | |||
|
91 | ||||
|
92 | [DebuggerStepThrough] | |||
|
93 | public static IPromise Run(Func<IPromise> action) { | |||
|
94 | ArgumentNotNull(action, "action"); | |||
|
95 | ||||
|
96 | try { | |||
|
97 | return action() ?? new FailedPromise(new Exception("The action returned null")); | |||
|
98 | } catch (Exception err) { | |||
|
99 | return new FailedPromise(err); | |||
|
100 | } | |||
|
101 | } | |||
|
102 | ||||
|
103 | [DebuggerStepThrough] | |||
|
104 | public static IPromise<T> Run<T>(Func<IPromise<T>> action) { | |||
119 | ArgumentNotNull(action, "action"); |
|
105 | ArgumentNotNull(action, "action"); | |
120 |
|
106 | |||
121 | try { |
|
107 | try { | |
122 | return action() ?? Promise<T>.FromException(new Exception("The action returned null")); |
|
108 | return action() ?? Promise<T>.FromException(new Exception("The action returned null")); | |
123 | } catch (Exception err) { |
|
109 | } catch (Exception err) { | |
124 | return Promise<T>.FromException(err); |
|
110 | return Promise<T>.FromException(err); | |
125 | } |
|
111 | } | |
126 | } |
|
112 | } | |
127 | } |
|
113 | } | |
128 | } |
|
114 | } |
@@ -1,111 +1,99 | |||||
1 | using System; |
|
1 | using System; | |
2 |
|
2 | |||
3 | namespace Implab { |
|
3 | namespace Implab { | |
4 | public class SuccessPromise : IPromise { |
|
4 | public class SuccessPromise : IPromise { | |
5 | #region IPromise implementation |
|
5 | #region IPromise implementation | |
6 |
|
6 | |||
7 | public IPromise On(Action success, Action<Exception> error, Action<Exception> cancel) { |
|
7 | public IPromise On(Action success, Action<Exception> error, Action<Exception> cancel) { | |
8 | if (success != null) { |
|
8 | if (success != null) { | |
9 | try { |
|
9 | try { | |
10 | success(); |
|
10 | success(); | |
11 | } catch(Exception err) { |
|
11 | // Analysis disable once EmptyGeneralCatchClause | |
12 | if (error != null) { |
|
12 | } catch { | |
13 | try { |
|
|||
14 | error(err); |
|
|||
15 | // Analysis disable once EmptyGeneralCatchClause |
|
|||
16 | } catch { |
|
|||
17 | } |
|
|||
18 | } |
|
|||
19 | } |
|
13 | } | |
20 | } |
|
14 | } | |
21 | return this; |
|
15 | return this; | |
22 | } |
|
16 | } | |
23 |
|
17 | |||
24 | public IPromise On(Action success, Action<Exception> error) { |
|
18 | public IPromise On(Action success, Action<Exception> error) { | |
25 | if (success != null) { |
|
19 | if (success != null) { | |
26 | try { |
|
20 | try { | |
27 | success(); |
|
21 | success(); | |
28 | } catch(Exception err) { |
|
22 | // Analysis disable once EmptyGeneralCatchClause | |
29 | if (error != null) { |
|
23 | } catch { | |
30 | try { |
|
|||
31 | error(err); |
|
|||
32 | // Analysis disable once EmptyGeneralCatchClause |
|
|||
33 | } catch { |
|
|||
34 | } |
|
|||
35 | } |
|
|||
36 | } |
|
24 | } | |
37 | } |
|
25 | } | |
38 | return this; |
|
26 | return this; | |
39 | } |
|
27 | } | |
40 |
|
28 | |||
41 | public IPromise On(Action success) { |
|
29 | public IPromise On(Action success) { | |
42 | if (success != null) { |
|
30 | if (success != null) { | |
43 | try { |
|
31 | try { | |
44 | success(); |
|
32 | success(); | |
45 | // Analysis disable once EmptyGeneralCatchClause |
|
33 | // Analysis disable once EmptyGeneralCatchClause | |
46 | } catch { |
|
34 | } catch { | |
47 | } |
|
35 | } | |
48 | } |
|
36 | } | |
49 | return this; |
|
37 | return this; | |
50 | } |
|
38 | } | |
51 |
|
39 | |||
52 | public IPromise On(Action handler, PromiseEventType events) { |
|
40 | public IPromise On(Action handler, PromiseEventType events) { | |
53 | if (handler != null && events.HasFlag(PromiseEventType.Success)) { |
|
41 | if (handler != null && events.HasFlag(PromiseEventType.Success)) { | |
54 | try { |
|
42 | try { | |
55 | handler(); |
|
43 | handler(); | |
56 | // Analysis disable once EmptyGeneralCatchClause |
|
44 | // Analysis disable once EmptyGeneralCatchClause | |
57 | } catch { |
|
45 | } catch { | |
58 | } |
|
46 | } | |
59 | } |
|
47 | } | |
60 | return this; |
|
48 | return this; | |
61 | } |
|
49 | } | |
62 |
|
50 | |||
63 | public IPromise<T> Cast<T>() { |
|
51 | public IPromise<T> Cast<T>() { | |
64 | throw new InvalidCastException(); |
|
52 | throw new InvalidCastException(); | |
65 | } |
|
53 | } | |
66 |
|
54 | |||
67 | public void Join() { |
|
55 | public void Join() { | |
68 | } |
|
56 | } | |
69 |
|
57 | |||
70 | public void Join(int timeout) { |
|
58 | public void Join(int timeout) { | |
71 | } |
|
59 | } | |
72 |
|
60 | |||
73 | public Type PromiseType { |
|
61 | public Type PromiseType { | |
74 | get { |
|
62 | get { | |
75 | return typeof(void); |
|
63 | return typeof(void); | |
76 | } |
|
64 | } | |
77 | } |
|
65 | } | |
78 |
|
66 | |||
79 | public bool IsResolved { |
|
67 | public bool IsResolved { | |
80 | get { |
|
68 | get { | |
81 | return true; |
|
69 | return true; | |
82 | } |
|
70 | } | |
83 | } |
|
71 | } | |
84 |
|
72 | |||
85 | public bool IsCancelled { |
|
73 | public bool IsCancelled { | |
86 | get { |
|
74 | get { | |
87 | return false; |
|
75 | return false; | |
88 | } |
|
76 | } | |
89 | } |
|
77 | } | |
90 |
|
78 | |||
91 | public Exception Error { |
|
79 | public Exception Error { | |
92 | get { |
|
80 | get { | |
93 | return null; |
|
81 | return null; | |
94 | } |
|
82 | } | |
95 | } |
|
83 | } | |
96 |
|
84 | |||
97 | #endregion |
|
85 | #endregion | |
98 |
|
86 | |||
99 | #region ICancellable implementation |
|
87 | #region ICancellable implementation | |
100 |
|
88 | |||
101 | public void Cancel() { |
|
89 | public void Cancel() { | |
102 | } |
|
90 | } | |
103 |
|
91 | |||
104 | public void Cancel(Exception reason) { |
|
92 | public void Cancel(Exception reason) { | |
105 | } |
|
93 | } | |
106 |
|
94 | |||
107 | #endregion |
|
95 | #endregion | |
108 |
|
96 | |||
109 | } |
|
97 | } | |
110 | } |
|
98 | } | |
111 |
|
99 |
@@ -1,177 +1,153 | |||||
1 | using System; |
|
1 | using System; | |
2 |
|
2 | |||
3 | namespace Implab { |
|
3 | namespace Implab { | |
4 | public class SuccessPromise<T> : IPromise<T> { |
|
4 | public class SuccessPromise<T> : IPromise<T> { | |
5 | readonly T m_value; |
|
5 | readonly T m_value; | |
6 |
|
6 | |||
7 | public SuccessPromise(T value){ |
|
7 | public SuccessPromise(T value){ | |
8 | m_value = value; |
|
8 | m_value = value; | |
9 | } |
|
9 | } | |
10 |
|
10 | |||
11 | public IPromise<T> On(Action<T> success, Action<Exception> error, Action<Exception> cancel) { |
|
11 | public IPromise<T> On(Action<T> success, Action<Exception> error, Action<Exception> cancel) { | |
12 | if (success != null) { |
|
12 | if (success != null) { | |
13 | try { |
|
13 | try { | |
14 | success(m_value); |
|
14 | success(m_value); | |
15 | } catch(Exception err) { |
|
15 | // Analysis disable once EmptyGeneralCatchClause | |
16 | if (error != null) { |
|
16 | } catch { | |
17 | try { |
|
|||
18 | error(err); |
|
|||
19 | // Analysis disable once EmptyGeneralCatchClause |
|
|||
20 | } catch { |
|
|||
21 | } |
|
|||
22 | } |
|
|||
23 | } |
|
17 | } | |
24 | } |
|
18 | } | |
25 | return this; |
|
19 | return this; | |
26 | } |
|
20 | } | |
27 |
|
21 | |||
28 | public IPromise<T> On(Action<T> success, Action<Exception> error) { |
|
22 | public IPromise<T> On(Action<T> success, Action<Exception> error) { | |
29 | if (success != null) { |
|
23 | if (success != null) { | |
30 | try { |
|
24 | try { | |
31 | success(m_value); |
|
25 | success(m_value); | |
32 | } catch(Exception err) { |
|
26 | // Analysis disable once EmptyGeneralCatchClause | |
33 | if (error != null) { |
|
27 | } catch { | |
34 | try { |
|
|||
35 | error(err); |
|
|||
36 | // Analysis disable once EmptyGeneralCatchClause |
|
|||
37 | } catch { |
|
|||
38 | } |
|
|||
39 | } |
|
|||
40 | } |
|
28 | } | |
41 | } |
|
29 | } | |
42 | return this; |
|
30 | return this; | |
43 | } |
|
31 | } | |
44 |
|
32 | |||
45 | public IPromise<T> On(Action<T> success) { |
|
33 | public IPromise<T> On(Action<T> success) { | |
46 | if (success != null) { |
|
34 | if (success != null) { | |
47 | try { |
|
35 | try { | |
48 | success(m_value); |
|
36 | success(m_value); | |
49 | // Analysis disable once EmptyGeneralCatchClause |
|
37 | // Analysis disable once EmptyGeneralCatchClause | |
50 | } catch { |
|
38 | } catch { | |
51 | } |
|
39 | } | |
52 | } |
|
40 | } | |
53 | return this; |
|
41 | return this; | |
54 | } |
|
42 | } | |
55 |
|
43 | |||
56 | public T Join() { |
|
44 | public T Join() { | |
57 | return m_value; |
|
45 | return m_value; | |
58 | } |
|
46 | } | |
59 |
|
47 | |||
60 | public T Join(int timeout) { |
|
48 | public T Join(int timeout) { | |
61 | return m_value; |
|
49 | return m_value; | |
62 | } |
|
50 | } | |
63 |
|
51 | |||
64 | public IPromise<T> On(Action success, Action<Exception> error, Action<Exception> cancel) { |
|
52 | public IPromise<T> On(Action success, Action<Exception> error, Action<Exception> cancel) { | |
65 | if (success != null) { |
|
53 | if (success != null) { | |
66 | try { |
|
54 | try { | |
67 | success(); |
|
55 | success(); | |
68 | } catch(Exception err) { |
|
56 | // Analysis disable once EmptyGeneralCatchClause | |
69 | if (error != null) { |
|
57 | } catch { | |
70 | try { |
|
|||
71 | error(err); |
|
|||
72 | // Analysis disable once EmptyGeneralCatchClause |
|
|||
73 | } catch { |
|
|||
74 | } |
|
|||
75 | } |
|
|||
76 | } |
|
58 | } | |
77 | } |
|
59 | } | |
78 | return this; |
|
60 | return this; | |
79 | } |
|
61 | } | |
80 |
|
62 | |||
81 | public IPromise<T> On(Action success, Action<Exception> error) { |
|
63 | public IPromise<T> On(Action success, Action<Exception> error) { | |
82 | if (success != null) { |
|
64 | if (success != null) { | |
83 | try { |
|
65 | try { | |
84 | success(); |
|
66 | success(); | |
85 | } catch(Exception err) { |
|
67 | // Analysis disable once EmptyGeneralCatchClause | |
86 | if (error != null) { |
|
68 | } catch { | |
87 | try { |
|
|||
88 | error(err); |
|
|||
89 | // Analysis disable once EmptyGeneralCatchClause |
|
|||
90 | } catch { |
|
|||
91 | } |
|
|||
92 | } |
|
|||
93 | } |
|
69 | } | |
94 | } |
|
70 | } | |
95 | return this; |
|
71 | return this; | |
96 | } |
|
72 | } | |
97 |
|
73 | |||
98 | public IPromise<T> On(Action success) { |
|
74 | public IPromise<T> On(Action success) { | |
99 | if (success != null) { |
|
75 | if (success != null) { | |
100 | try { |
|
76 | try { | |
101 | success(); |
|
77 | success(); | |
102 | // Analysis disable once EmptyGeneralCatchClause |
|
78 | // Analysis disable once EmptyGeneralCatchClause | |
103 | } catch { |
|
79 | } catch { | |
104 | } |
|
80 | } | |
105 | } |
|
81 | } | |
106 | return this; |
|
82 | return this; | |
107 | } |
|
83 | } | |
108 |
|
84 | |||
109 | public IPromise<T> On(Action handler, PromiseEventType events) { |
|
85 | public IPromise<T> On(Action handler, PromiseEventType events) { | |
110 | if (handler != null && events.HasFlag(PromiseEventType.Success)) { |
|
86 | if (handler != null && events.HasFlag(PromiseEventType.Success)) { | |
111 | try { |
|
87 | try { | |
112 | handler(); |
|
88 | handler(); | |
113 | // Analysis disable once EmptyGeneralCatchClause |
|
89 | // Analysis disable once EmptyGeneralCatchClause | |
114 | } catch { |
|
90 | } catch { | |
115 | } |
|
91 | } | |
116 | } |
|
92 | } | |
117 | return this; |
|
93 | return this; | |
118 | } |
|
94 | } | |
119 |
|
95 | |||
120 | IPromise IPromise.On(Action success, Action<Exception> error, Action<Exception> cancel) { |
|
96 | IPromise IPromise.On(Action success, Action<Exception> error, Action<Exception> cancel) { | |
121 | return On(success, error, cancel); |
|
97 | return On(success, error, cancel); | |
122 | } |
|
98 | } | |
123 |
|
99 | |||
124 | IPromise IPromise.On(Action success, Action<Exception> error) { |
|
100 | IPromise IPromise.On(Action success, Action<Exception> error) { | |
125 | return On(success, error); |
|
101 | return On(success, error); | |
126 | } |
|
102 | } | |
127 |
|
103 | |||
128 | IPromise IPromise.On(Action success) { |
|
104 | IPromise IPromise.On(Action success) { | |
129 | return On(success); |
|
105 | return On(success); | |
130 | } |
|
106 | } | |
131 |
|
107 | |||
132 | IPromise IPromise.On(Action handler, PromiseEventType events) { |
|
108 | IPromise IPromise.On(Action handler, PromiseEventType events) { | |
133 | return On(handler, events); |
|
109 | return On(handler, events); | |
134 | } |
|
110 | } | |
135 |
|
111 | |||
136 | public IPromise<T2> Cast<T2>() { |
|
112 | public IPromise<T2> Cast<T2>() { | |
137 | return new SuccessPromise<T2>((T2)(object)m_value); |
|
113 | return new SuccessPromise<T2>((T2)(object)m_value); | |
138 | } |
|
114 | } | |
139 |
|
115 | |||
140 | void IPromise.Join() { |
|
116 | void IPromise.Join() { | |
141 | } |
|
117 | } | |
142 |
|
118 | |||
143 | void IPromise.Join(int timeout) { |
|
119 | void IPromise.Join(int timeout) { | |
144 | } |
|
120 | } | |
145 |
|
121 | |||
146 | public Type PromiseType { |
|
122 | public Type PromiseType { | |
147 | get { |
|
123 | get { | |
148 | return typeof(T); |
|
124 | return typeof(T); | |
149 | } |
|
125 | } | |
150 | } |
|
126 | } | |
151 |
|
127 | |||
152 | public bool IsResolved { |
|
128 | public bool IsResolved { | |
153 | get { |
|
129 | get { | |
154 | return true; |
|
130 | return true; | |
155 | } |
|
131 | } | |
156 | } |
|
132 | } | |
157 |
|
133 | |||
158 | public bool IsCancelled { |
|
134 | public bool IsCancelled { | |
159 | get { |
|
135 | get { | |
160 | return false; |
|
136 | return false; | |
161 | } |
|
137 | } | |
162 | } |
|
138 | } | |
163 |
|
139 | |||
164 | public Exception Error { |
|
140 | public Exception Error { | |
165 | get { |
|
141 | get { | |
166 | return null; |
|
142 | return null; | |
167 | } |
|
143 | } | |
168 | } |
|
144 | } | |
169 |
|
145 | |||
170 | public void Cancel() { |
|
146 | public void Cancel() { | |
171 | } |
|
147 | } | |
172 |
|
148 | |||
173 | public void Cancel(Exception reason) { |
|
149 | public void Cancel(Exception reason) { | |
174 | } |
|
150 | } | |
175 | } |
|
151 | } | |
176 | } |
|
152 | } | |
177 |
|
153 |
1 | NO CONTENT: file was removed |
|
NO CONTENT: file was removed |
General Comments 3
ok, latest stable version should be in default
You need to be logged in to leave comments.
Login now