|
248
|
1 using System;
|
|
|
2 using System.Diagnostics;
|
|
|
3
|
|
|
4 namespace Implab {
|
|
|
5 class PromiseHandler {
|
|
249
|
6 public static Action<T, Deferred> Create<T>(Action<T> handler) {
|
|
248
|
7 Debug.Assert(handler != null);
|
|
|
8
|
|
249
|
9 return (v, next) => {
|
|
248
|
10 try {
|
|
|
11 handler(v);
|
|
|
12 next.Resolve();
|
|
|
13 } catch (Exception err) {
|
|
|
14 next.Reject(err);
|
|
|
15 }
|
|
|
16 };
|
|
|
17 }
|
|
|
18
|
|
249
|
19 public static Action<T, Deferred> Create<T>(Func<T, IPromise> handler) {
|
|
248
|
20 Debug.Assert(handler != null);
|
|
|
21
|
|
249
|
22 return (v, next) => {
|
|
248
|
23 try {
|
|
|
24 next.Resolve(handler(v));
|
|
|
25 } catch (Exception err) {
|
|
|
26 next.Reject(err);
|
|
|
27 }
|
|
|
28 };
|
|
|
29 }
|
|
|
30
|
|
249
|
31 public static Action<T, Deferred<T2>> Create<T, T2>(Func<T, T2> handler) {
|
|
248
|
32 Debug.Assert(handler != null);
|
|
|
33
|
|
249
|
34 return (v, next) => {
|
|
248
|
35 try {
|
|
|
36 next.Resolve(handler(v));
|
|
|
37 } catch (Exception err) {
|
|
|
38 next.Reject(err);
|
|
|
39 }
|
|
|
40 };
|
|
|
41 }
|
|
|
42
|
|
249
|
43 public static Action<T, Deferred<T2>> Create<T, T2>(Func<T, IPromise<T2>> handler) {
|
|
248
|
44 Debug.Assert(handler != null);
|
|
249
|
45 return (v, next) => {
|
|
248
|
46 try {
|
|
|
47 next.Resolve(handler(v));
|
|
|
48 } catch (Exception err) {
|
|
|
49 next.Reject(err);
|
|
|
50 }
|
|
|
51 };
|
|
|
52 }
|
|
|
53
|
|
249
|
54 public static Action<Deferred> Create(Action handler) {
|
|
248
|
55 Debug.Assert(handler != null);
|
|
|
56
|
|
249
|
57 return (next) => {
|
|
248
|
58 try {
|
|
|
59 handler();
|
|
|
60 next.Resolve();
|
|
|
61 } catch (Exception err) {
|
|
|
62 next.Reject(err);
|
|
|
63 }
|
|
|
64 };
|
|
|
65 }
|
|
|
66
|
|
249
|
67 public static Action<Deferred> Create(Func<IPromise> handler) {
|
|
248
|
68 Debug.Assert(handler != null);
|
|
|
69
|
|
249
|
70 return (next) => {
|
|
248
|
71 try {
|
|
|
72 next.Resolve(handler());
|
|
|
73 } catch (Exception err) {
|
|
|
74 next.Reject(err);
|
|
|
75 }
|
|
|
76 };
|
|
|
77 }
|
|
|
78
|
|
249
|
79 public static Action<Deferred<T2>> Create<T2>(Func<T2> handler) {
|
|
248
|
80 Debug.Assert(handler != null);
|
|
|
81
|
|
249
|
82 return (next) => {
|
|
248
|
83 try {
|
|
|
84 next.Resolve(handler());
|
|
|
85 } catch (Exception err) {
|
|
|
86 next.Reject(err);
|
|
|
87 }
|
|
|
88 };
|
|
|
89 }
|
|
|
90
|
|
249
|
91 public static Action<Deferred<T2>> Create<T2>(Func<IPromise<T2>> handler) {
|
|
248
|
92 Debug.Assert(handler != null);
|
|
249
|
93 return (next) => {
|
|
248
|
94 try {
|
|
|
95 next.Resolve(handler());
|
|
|
96 } catch (Exception err) {
|
|
|
97 next.Reject(err);
|
|
|
98 }
|
|
|
99 };
|
|
|
100 }
|
|
|
101 }
|
|
|
102 } |
