1 write to _requestBodyCancellationSource
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (1)
81_requestBodyCancellationSource = new CancellationTokenSource();
10 references to _requestBodyCancellationSource
System.Net.Http (10)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (10)
151_requestBodyCancellationSource.Cancel(); 162CancellationTokenRegistration linkedTokenRegistration = cancellationToken.UnsafeRegister(cts => ((CancellationTokenSource)cts!).Cancel(), _requestBodyCancellationSource); 184await FlushSendBufferAsync(endStream: _request.Content == null, _requestBodyCancellationSource.Token).ConfigureAwait(false); 188? SendContentAsync(_request.Content, _requestBodyCancellationSource.Token) 193Task readResponseTask = ReadResponseAsync(_requestBodyCancellationSource.Token); 245await writesClosed.WaitAsync(_requestBodyCancellationSource.Token).ConfigureAwait(false); 264await DrainContentLength0Frames(_requestBodyCancellationSource.Token).ConfigureAwait(false); 345catch (OperationCanceledException ex) when (ex.CancellationToken == _requestBodyCancellationSource.Token || ex.CancellationToken == cancellationToken) 355Debug.Assert(_requestBodyCancellationSource.IsCancellationRequested); 390_requestBodyCancellationSource.Cancel();