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();
150
CancellationTokenRegistration linkedTokenRegistration = cancellationToken.UnsafeRegister(cts => ((CancellationTokenSource)cts!).Cancel(),
_requestBodyCancellationSource
);
172
await FlushSendBufferAsync(endStream: _request.Content == null,
_requestBodyCancellationSource
.Token).ConfigureAwait(false);
176
? SendContentAsync(_request.Content,
_requestBodyCancellationSource
.Token)
181
Task readResponseTask = ReadResponseAsync(
_requestBodyCancellationSource
.Token);
223
await writesClosed.WaitAsync(
_requestBodyCancellationSource
.Token).ConfigureAwait(false);
244
await DrainContentLength0Frames(
_requestBodyCancellationSource
.Token).ConfigureAwait(false);
319
catch (OperationCanceledException ex) when (ex.CancellationToken ==
_requestBodyCancellationSource
.Token || ex.CancellationToken == cancellationToken)
329
Debug.Assert(
_requestBodyCancellationSource
.IsCancellationRequested);
364
_requestBodyCancellationSource
.Cancel();