@@ -198,8 +198,8 @@ private async Task SendToMultipleUsers(string hubName)
198
198
{
199
199
InitializeUserByQuerystring ( host ) ;
200
200
201
- var wh1 = new AsyncManualResetEvent ( ) ;
202
- var wh2 = new AsyncManualResetEvent ( ) ;
201
+ var wh1 = new TaskCompletionSource < object > ( ) ;
202
+ var wh2 = new TaskCompletionSource < object > ( ) ;
203
203
204
204
var connection1 = GetUserConnection ( "myUser" ) ;
205
205
var connection2 = GetUserConnection ( "myUser2" ) ;
@@ -210,16 +210,16 @@ private async Task SendToMultipleUsers(string hubName)
210
210
var proxy1 = connection1 . CreateHubProxy ( hubName ) ;
211
211
var proxy2 = connection2 . CreateHubProxy ( hubName ) ;
212
212
213
- proxy1 . On ( "send" , wh1 . Set ) ;
214
- proxy1 . On ( "send" , wh2 . Set ) ;
213
+ proxy1 . On ( "send" , ( ) => wh1 . TrySetResult ( null ) ) ;
214
+ proxy1 . On ( "send" , ( ) => wh2 . TrySetResult ( null ) ) ;
215
215
216
216
await connection1 . Start ( host ) ;
217
217
await connection2 . Start ( host ) ;
218
218
219
219
await proxy1 . Invoke ( "SendToUsers" , new List < string > { "myUser" , "myUser2" } ) ;
220
220
221
- Assert . True ( await wh1 . WaitAsync ( TimeSpan . FromSeconds ( 5 ) ) ) ;
222
- Assert . True ( await wh2 . WaitAsync ( TimeSpan . FromSeconds ( 5 ) ) ) ;
221
+ await wh1 . Task . OrTimeout ( ) ;
222
+ await wh2 . Task . OrTimeout ( ) ;
223
223
}
224
224
}
225
225
}
0 commit comments