1 write to _requestBodyCancellationSource
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (1)
79_requestBodyCancellationSource = new CancellationTokenSource();
9 references to _requestBodyCancellationSource
System.Net.Http (9)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (9)
125_requestBodyCancellationSource.Cancel(); 136CancellationTokenRegistration linkedTokenRegistration = cancellationToken.UnsafeRegister(cts => ((CancellationTokenSource)cts!).Cancel(), _requestBodyCancellationSource); 158await FlushSendBufferAsync(endStream: _request.Content == null, _requestBodyCancellationSource.Token).ConfigureAwait(false); 164sendRequestTask = SendContentAsync(_request.Content!, _requestBodyCancellationSource.Token); 173Task readResponseTask = ReadResponseAsync(_requestBodyCancellationSource.Token); 219await DrainContentLength0Frames(_requestBodyCancellationSource.Token).ConfigureAwait(false); 288catch (OperationCanceledException ex) when (ex.CancellationToken == _requestBodyCancellationSource.Token || ex.CancellationToken == cancellationToken) 298Debug.Assert(_requestBodyCancellationSource.IsCancellationRequested); 333_requestBodyCancellationSource.Cancel();