File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -46,7 +46,8 @@ public class TestConnectionRecoveryBase : IntegrationFixture
46
46
protected const ushort TotalMessageCount = 16384 ;
47
47
protected const ushort CloseAtCount = 16 ;
48
48
49
- public TestConnectionRecoveryBase ( ITestOutputHelper output ) : base ( output )
49
+ public TestConnectionRecoveryBase ( ITestOutputHelper output , bool dispatchConsumersAsync = false )
50
+ : base ( output , dispatchConsumersAsync : dispatchConsumersAsync )
50
51
{
51
52
_messageBody = GetRandomBody ( 4096 ) ;
52
53
}
@@ -226,7 +227,7 @@ protected static TaskCompletionSource<bool> PrepareForShutdown(IConnection conn)
226
227
var tcs = new TaskCompletionSource < bool > ( TaskCreationOptions . RunContinuationsAsynchronously ) ;
227
228
228
229
AutorecoveringConnection aconn = conn as AutorecoveringConnection ;
229
- aconn . ConnectionShutdown += ( c , args ) => tcs . SetResult ( true ) ;
230
+ aconn . ConnectionShutdown += ( c , args ) => tcs . TrySetResult ( true ) ;
230
231
231
232
return tcs ;
232
233
}
You can’t perform that action at this time.
0 commit comments