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)
187Debug.Assert(_requestBodyCancellationSource != null); 205sendRequestContent = await WaitFor100ContinueAsync(_requestBodyCancellationSource.Token).ConfigureAwait(false); 214ValueTask vt = _request.Content.InternalCopyToAsync(writeStream, context: null, _requestBodyCancellationSource.Token); 415requestBodyCancellationSource = _requestBodyCancellationSource; 987requestBodyCancellationSource = _requestBodyCancellationSource; 1268Debug.Assert(_requestBodyCancellationSource != null); 1271CancellationTokenRegistration linkedRegistration = cancellationToken.CanBeCanceled && cancellationToken != _requestBodyCancellationSource.Token ? 1298_creditWaiter = new CreditWaiter(_requestBodyCancellationSource.Token); 1302_creditWaiter.ResetForAwait(_requestBodyCancellationSource.Token); 1329await _connection.SendStreamDataAsync(StreamId, current, flush, _requestBodyCancellationSource.Token).ConfigureAwait(false); 1332catch (OperationCanceledException e) when (e.CancellationToken == _requestBodyCancellationSource.Token) 1412cancellationToken.UnsafeRegister(static s => ((CancellationTokenSource)s!).Cancel(), _requestBodyCancellationSource);