2 writes to _requestBodyCancellationSource
System.Net.Http (2)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (2)
115
_requestBodyCancellationSource
= new CancellationTokenSource();
127
_requestBodyCancellationSource
= new CancellationTokenSource();
12 references to _requestBodyCancellationSource
System.Net.Http (12)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (12)
187
Debug.Assert(
_requestBodyCancellationSource
!= null);
205
sendRequestContent = await WaitFor100ContinueAsync(
_requestBodyCancellationSource
.Token).ConfigureAwait(false);
214
ValueTask vt = _request.Content.InternalCopyToAsync(writeStream, context: null,
_requestBodyCancellationSource
.Token);
415
requestBodyCancellationSource =
_requestBodyCancellationSource
;
987
requestBodyCancellationSource =
_requestBodyCancellationSource
;
1268
Debug.Assert(
_requestBodyCancellationSource
!= null);
1271
CancellationTokenRegistration linkedRegistration = cancellationToken.CanBeCanceled && cancellationToken !=
_requestBodyCancellationSource
.Token ?
1298
_creditWaiter = new CreditWaiter(
_requestBodyCancellationSource
.Token);
1302
_creditWaiter.ResetForAwait(
_requestBodyCancellationSource
.Token);
1329
await _connection.SendStreamDataAsync(StreamId, current, flush,
_requestBodyCancellationSource
.Token).ConfigureAwait(false);
1332
catch (OperationCanceledException e) when (e.CancellationToken ==
_requestBodyCancellationSource
.Token)
1412
cancellationToken.UnsafeRegister(static s => ((CancellationTokenSource)s!).Cancel(),
_requestBodyCancellationSource
);