@@ -418,22 +418,22 @@ public async Task TestCloseAfterSend(Type hostConfiguratorType)
418
418
await s . CloseAsync ( CloseReason . LocalClosing ) ;
419
419
} ) . BuildAsServer ( ) as IServer )
420
420
{
421
- Assert . True ( await server . StartAsync ( ) ) ;
421
+ Assert . True ( await server . StartAsync ( TestContext . Current . CancellationToken ) ) ;
422
422
Assert . Equal ( 0 , server . SessionCount ) ;
423
423
424
424
var client = new Socket ( AddressFamily . InterNetwork , SocketType . Stream , ProtocolType . Tcp ) ;
425
- await client . ConnectAsync ( hostConfigurator . GetServerEndPoint ( ) ) ;
425
+ await client . ConnectAsync ( hostConfigurator . GetServerEndPoint ( ) , TestContext . Current . CancellationToken ) ;
426
426
using ( var stream = await hostConfigurator . GetClientStream ( client ) )
427
427
using ( var streamReader = new StreamReader ( stream , Utf8Encoding , true ) )
428
428
using ( var streamWriter = new StreamWriter ( stream , Utf8Encoding , 1024 * 1024 * 4 ) )
429
429
{
430
430
await streamWriter . WriteAsync ( "Hello World\r \n " ) ;
431
- await streamWriter . FlushAsync ( ) ;
432
- var line = await streamReader . ReadLineAsync ( ) ;
431
+ await streamWriter . FlushAsync ( TestContext . Current . CancellationToken ) ;
432
+ var line = await streamReader . ReadLineAsync ( TestContext . Current . CancellationToken ) ;
433
433
Assert . Equal ( "Hello World" , line ) ;
434
434
}
435
435
436
- await server . StopAsync ( ) ;
436
+ await server . StopAsync ( TestContext . Current . CancellationToken ) ;
437
437
}
438
438
}
439
439
0 commit comments