@@ -399,7 +399,7 @@ private async Task SendAsyncCore(ArraySegment<byte> buffer, WebSocketMessageType
399
399
400
400
if ( sendTask != null ) // this is optimization for single-threaded build, see resolvedPromise() in web-socket.ts. Null means synchronously resolved.
401
401
{
402
- await CancellationHelper ( sendTask , cancellationToken , previousState , pinBuffer ) . ConfigureAwait ( false ) ;
402
+ await CancellationHelper ( sendTask , cancellationToken , previousState ) . ConfigureAwait ( false ) ;
403
403
}
404
404
}
405
405
catch ( JSException ex )
@@ -442,7 +442,7 @@ private async Task<WebSocketReceiveResult> ReceiveAsyncCore(ArraySegment<byte> b
442
442
443
443
if ( receiveTask != null ) // this is optimization for single-threaded build, see resolvedPromise() in web-socket.ts. Null means synchronously resolved.
444
444
{
445
- await CancellationHelper ( receiveTask , cancellationToken , previousState , pinBuffer ) . ConfigureAwait ( false ) ;
445
+ await CancellationHelper ( receiveTask , cancellationToken , previousState ) . ConfigureAwait ( false ) ;
446
446
}
447
447
448
448
return ConvertResponse ( ) ;
@@ -550,13 +550,12 @@ private async Task CloseAsyncCore(WebSocketCloseStatus closeStatus, string? stat
550
550
}
551
551
}
552
552
553
- private async Task CancellationHelper ( Task promise , CancellationToken cancellationToken , WebSocketState previousState , IDisposable ? disposable = null )
553
+ private async Task CancellationHelper ( Task promise , CancellationToken cancellationToken , WebSocketState previousState )
554
554
{
555
555
try
556
556
{
557
557
if ( promise . IsCompletedSuccessfully )
558
558
{
559
- disposable ? . Dispose ( ) ;
560
559
return ;
561
560
}
562
561
if ( promise . IsCompleted )
@@ -602,10 +601,6 @@ private async Task CancellationHelper(Task promise, CancellationToken cancellati
602
601
throw new WebSocketException ( WebSocketError . NativeError , ex ) ;
603
602
}
604
603
}
605
- finally
606
- {
607
- disposable ? . Dispose ( ) ;
608
- }
609
604
}
610
605
611
606
// needs to be called with locked _lockObject
0 commit comments