1 write to _stopCts
Microsoft.AspNetCore.Http.Connections.Client (1)
Internal\WebSocketsTransport.cs (1)
315
_stopCts
= new CancellationTokenSource();
9 references to _stopCts
Microsoft.AspNetCore.Http.Connections.Client (9)
Internal\WebSocketsTransport.cs (9)
356
_stopCts
.CancelAfter(_closeTimeout);
367
var resultTask = await Task.WhenAny(sending, Task.Delay(_closeTimeout,
_stopCts
.Token)).ConfigureAwait(false);
443
var result = await socket.ReceiveAsync(Memory<byte>.Empty,
_stopCts
.Token).ConfigureAwait(false);
461
var receiveResult = await socket.ReceiveAsync(memory,
_stopCts
.Token).ConfigureAwait(false);
562
await socket.SendAsync(buffer, _webSocketMessageType,
_stopCts
.Token).ConfigureAwait(false);
602
await socket.CloseOutputAsync(error != null ? WebSocketCloseStatus.InternalServerError : WebSocketCloseStatus.NormalClosure, "",
_stopCts
.Token).ConfigureAwait(false);
608
await socket.CloseAsync(error != null ? WebSocketCloseStatus.InternalServerError : WebSocketCloseStatus.NormalClosure, "",
_stopCts
.Token).ConfigureAwait(false);
673
_stopCts
.CancelAfter(_closeTimeout);
688
_stopCts
.Dispose();