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); 367var resultTask = await Task.WhenAny(sending, Task.Delay(_closeTimeout, _stopCts.Token)).ConfigureAwait(false); 443var result = await socket.ReceiveAsync(Memory<byte>.Empty, _stopCts.Token).ConfigureAwait(false); 461var receiveResult = await socket.ReceiveAsync(memory, _stopCts.Token).ConfigureAwait(false); 562await socket.SendAsync(buffer, _webSocketMessageType, _stopCts.Token).ConfigureAwait(false); 602await socket.CloseOutputAsync(error != null ? WebSocketCloseStatus.InternalServerError : WebSocketCloseStatus.NormalClosure, "", _stopCts.Token).ConfigureAwait(false); 608await socket.CloseAsync(error != null ? WebSocketCloseStatus.InternalServerError : WebSocketCloseStatus.NormalClosure, "", _stopCts.Token).ConfigureAwait(false); 673_stopCts.CancelAfter(_closeTimeout); 688_stopCts.Dispose();