1 instantiation of Http2Stream
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
1641var http2Stream = new Http2Stream(request, this);
41 references to Http2Stream
System.Net.Http (41)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (22)
41private readonly Dictionary<int, Http2Stream> _httpStreams; 143_httpStreams = new Dictionary<int, Http2Stream>(); 614private Http2Stream? GetStream(int streamId) 623if (!_httpStreams.TryGetValue(streamId, out Http2Stream? http2Stream)) 640Http2Stream? http2Stream = GetStream(streamId); 769Http2Stream? http2Stream = GetStream(frameHeader.StreamId); 943foreach (KeyValuePair<int, Http2Stream> kvp in _httpStreams) 1024Http2Stream? http2Stream = GetStream(frameHeader.StreamId); 1049Http2Stream? http2Stream = GetStream(frameHeader.StreamId); 1077List<Http2Stream> streamsToAbort = new List<Http2Stream>(); 1082foreach (KeyValuePair<int, Http2Stream> kvp in _httpStreams) 1095foreach (Http2Stream s in streamsToAbort) 1574private void AddStream(Http2Stream http2Stream) 1620private async ValueTask<Http2Stream> SendHeadersAsync(HttpRequestMessage request, CancellationToken cancellationToken, bool mustFlush) 1641var http2Stream = new Http2Stream(request, this); 1808List<Http2Stream> streamsToAbort = new List<Http2Stream>(); 1821foreach (KeyValuePair<int, Http2Stream> kvp in _httpStreams) 1831foreach (Http2Stream s in streamsToAbort) 1994Http2Stream http2Stream = await SendHeadersAsync(request, cancellationToken, mustFlush: shouldExpectContinue || request.IsExtendedConnectRequest).ConfigureAwait(false); 2062private void RemoveStream(Http2Stream http2Stream)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (15)
350var thisRef = (Http2Stream)s!; 1456var thisRef = (Http2Stream)s!; 1500public Http2ReadStream(Http2Stream http2Stream) : base(http2Stream, closeResponseBodyOnDispose: true) { } 1515public Http2WriteStream(Http2Stream http2Stream, long contentLength) : base(http2Stream) 1546private Http2Stream? _http2Stream; 1549public Http2ReadWriteStream(Http2Stream http2Stream, bool closeResponseBodyOnDispose = false) 1575Http2Stream? http2Stream = Interlocked.Exchange(ref _http2Stream, null); 1599Http2Stream? http2Stream = _http2Stream; 1607Http2Stream? http2Stream = _http2Stream; 1625Http2Stream http2Stream = _http2Stream ?? throw ExceptionDispatchInfo.SetCurrentStackTrace(new ObjectDisposedException(nameof(Http2ReadStream))); 1632Http2Stream? http2Stream = _http2Stream; 1642Http2Stream? http2Stream = _http2Stream; 1659Http2Stream? http2Stream = _http2Stream;
System\Net\Http\SocketsHttpHandler\Http2StreamWindowManager.cs (4)
23public Http2StreamWindowManager(Http2Connection connection, Http2Stream stream) 46public void AdjustWindow(int bytesConsumed, Http2Stream stream) 69private void AjdustWindowStatic(int bytesConsumed, Http2Stream stream) 85private void AdjustWindowDynamic(int bytesConsumed, Http2Stream stream)