@@ -85,9 +85,10 @@ public async Task Execute_DoAndHttp_ShouldSuccess()
85
85
workflow . NewBranch ( ) . OnRollback ( async ( barrier ) =>
86
86
{
87
87
_testOutputHelper . WriteLine ( "1. local rollback" ) ;
88
+ await Task . CompletedTask ;
88
89
} ) . Do ( async ( barrier ) =>
89
90
{
90
- return ( "my result"u8 . ToArray ( ) , null ) ;
91
+ return await Task . FromResult < ( byte [ ] , Exception ) > ( ( "my result"u8 . ToArray ( ) , null ) ) ;
91
92
} ) ;
92
93
93
94
// 2. http1, SAGA
@@ -101,7 +102,6 @@ public async Task Execute_DoAndHttp_ShouldSuccess()
101
102
HttpResponseMessage httpResult2 = await workflow . NewBranch ( ) . OnRollback ( async ( barrier ) =>
102
103
{
103
104
_testOutputHelper . WriteLine ( "4. http2 cancel" ) ;
104
-
105
105
await workflow . NewRequest ( ) . GetAsync ( "http://localhost:5006/test-http-ok1" ) ;
106
106
} ) . OnCommit ( async ( barrier ) =>
107
107
{
@@ -176,21 +176,24 @@ public async Task Execute_DoAndHttp_Failed()
176
176
workflow . NewBranch ( ) . OnRollback ( async ( barrier ) =>
177
177
{
178
178
_testOutputHelper . WriteLine ( "1. local rollback" ) ;
179
+ await Task . CompletedTask ;
179
180
} ) . Do ( async ( barrier ) =>
180
181
{
181
- return ( "my result"u8 . ToArray ( ) , null ) ;
182
+ return await Task . FromResult < ( byte [ ] , Exception ) > ( ( "my result"u8 . ToArray ( ) , null ) ) ;
182
183
} ) ;
183
184
184
185
// 2. http1
185
186
HttpResponseMessage httpResult1 = await workflow . NewBranch ( ) . OnRollback ( async ( barrier ) =>
186
187
{
187
188
_testOutputHelper . WriteLine ( "4. http1 rollback" ) ;
189
+ await Task . CompletedTask ;
188
190
} ) . NewRequest ( ) . GetAsync ( "http://localhost:5006/test-http-ok1" ) ;
189
191
190
192
// 3. http2
191
193
HttpResponseMessage httpResult2 = await workflow . NewBranch ( ) . OnRollback ( async ( barrier ) =>
192
194
{
193
195
_testOutputHelper . WriteLine ( "4. http2 rollback" ) ;
196
+ await Task . CompletedTask ;
194
197
} ) . NewRequest ( ) . GetAsync ( "http://localhost:5006/409" ) ; // 409
195
198
196
199
return await Task . FromResult ( "my result"u8 . ToArray ( ) ) ;
0 commit comments