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();
136
CancellationTokenRegistration linkedTokenRegistration = cancellationToken.UnsafeRegister(cts => ((CancellationTokenSource)cts!).Cancel(),
_requestBodyCancellationSource
);
158
await FlushSendBufferAsync(endStream: _request.Content == null,
_requestBodyCancellationSource
.Token).ConfigureAwait(false);
164
sendRequestTask = SendContentAsync(_request.Content!,
_requestBodyCancellationSource
.Token);
173
Task readResponseTask = ReadResponseAsync(
_requestBodyCancellationSource
.Token);
219
await DrainContentLength0Frames(
_requestBodyCancellationSource
.Token).ConfigureAwait(false);
288
catch (OperationCanceledException ex) when (ex.CancellationToken ==
_requestBodyCancellationSource
.Token || ex.CancellationToken == cancellationToken)
298
Debug.Assert(
_requestBodyCancellationSource
.IsCancellationRequested);
333
_requestBodyCancellationSource
.Cancel();