1 write to StreamId
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (1)
149StreamId = streamId;
19 references to StreamId
System.Net.Http (19)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (11)
1085Debug.Assert(streamId == kvp.Value.StreamId); 1616_httpStreams.Add(http2Stream.StreamId, http2Stream); 1650if (NetEventSource.Log.IsEnabled()) s.thisRef.Trace(s.http2Stream.StreamId, $"Started writing. Total header bytes={s.headerBytes.Length}"); 1659FrameHeader.WriteTo(span, current.Length, FrameType.Headers, flags, s.http2Stream.StreamId); 1663if (NetEventSource.Log.IsEnabled()) s.thisRef.Trace(s.http2Stream.StreamId, $"Wrote HEADERS frame. Length={current.Length}, flags={flags}"); 1671FrameHeader.WriteTo(span, current.Length, FrameType.Continuation, flags, s.http2Stream.StreamId); 1675if (NetEventSource.Log.IsEnabled()) s.thisRef.Trace(s.http2Stream.StreamId, $"Wrote CONTINUATION frame. Length={current.Length}, flags={flags}"); 1824Debug.Assert(streamId == kvp.Value.StreamId); 2064if (NetEventSource.Log.IsEnabled()) Trace(http2Stream.StreamId, ""); 2068if (!_httpStreams.Remove(http2Stream.StreamId)) 2070Debug.Fail($"Stream {http2Stream.StreamId} not found in dictionary during RemoveStream???");
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (6)
317_connection.LogExceptions(_connection.SendEndStreamAsync(StreamId)); 377_connection.LogExceptions(_connection.SendRstStreamAsync(StreamId, Http2ProtocolErrorCode.Cancel)); 1329await _connection.SendStreamDataAsync(StreamId, current, flush, _requestBodyCancellationSource.Token).ConfigureAwait(false); 1371_connection.LogExceptions(_connection.SendEndStreamAsync(StreamId)); 1396_connection.LogExceptions(_connection.SendRstStreamAsync(StreamId, Http2ProtocolErrorCode.Cancel)); 1478_connection.Trace(StreamId, message, memberName);
System\Net\Http\SocketsHttpHandler\Http2StreamWindowManager.cs (2)
81Task sendWindowUpdateTask = connection.SendWindowUpdateAsync(stream.StreamId, windowUpdateIncrement); 130Task sendWindowUpdateTask = connection.SendWindowUpdateAsync(stream.StreamId, windowUpdateIncrement);