1 write to _requestBodyCancellationSource
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (1)
79_requestBodyCancellationSource = new CancellationTokenSource();
10 references to _requestBodyCancellationSource
System.Net.Http (10)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (10)
139_requestBodyCancellationSource.Cancel(); 150CancellationTokenRegistration linkedTokenRegistration = cancellationToken.UnsafeRegister(cts => ((CancellationTokenSource)cts!).Cancel(), _requestBodyCancellationSource); 172await FlushSendBufferAsync(endStream: _request.Content == null, _requestBodyCancellationSource.Token).ConfigureAwait(false); 176? SendContentAsync(_request.Content, _requestBodyCancellationSource.Token) 181Task readResponseTask = ReadResponseAsync(_requestBodyCancellationSource.Token); 223await writesClosed.WaitAsync(_requestBodyCancellationSource.Token).ConfigureAwait(false); 244await DrainContentLength0Frames(_requestBodyCancellationSource.Token).ConfigureAwait(false); 319catch (OperationCanceledException ex) when (ex.CancellationToken == _requestBodyCancellationSource.Token || ex.CancellationToken == cancellationToken) 329Debug.Assert(_requestBodyCancellationSource.IsCancellationRequested); 364_requestBodyCancellationSource.Cancel();