1 type derived from Http2Stream
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http2\Http2StreamOfT.cs (1)
11internal sealed class Http2Stream<TContext> : Http2Stream, IHostContextContainer<TContext> where TContext : notnull
38 references to Http2Stream
Microsoft.AspNetCore.Server.Kestrel.Core (38)
Internal\Http2\FlowControl\StreamInputFlowControl.cs (3)
16/// <see cref="Http2Stream"/> owns an instance for the stream-level flow control. 27private readonly Http2Stream _stream; 31Http2Stream stream,
Internal\Http2\Http2Connection.cs (23)
122private Http2Stream? _currentHeadersStream; 140private readonly ConcurrentQueue<Http2Stream> _completedStreams = new ConcurrentQueue<Http2Stream>(); 148internal readonly Dictionary<int, Http2Stream> _streams = new Dictionary<int, Http2Stream>(); 149internal PooledStreamStack<Http2Stream> StreamPool; 189StreamPool = new PooledStreamStack<Http2Stream>(Math.Min(InitialStreamPoolSize, http2Limits.MaxStreamsPerConnection)); 455foreach (var stream in _streams.Values) 474while (StreamPool.TryPop(out var pooledStream)) 723if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 760private Http2ConnectionErrorException CreateReceivedFrameStreamAbortedException(Http2Stream stream) 808if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 876private Http2Stream GetStream<TContext>(IHttpApplication<TContext> application) where TContext : notnull 878if (StreamPool.TryPop(out var stream)) 958if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 1030foreach (var stream in _streams.Values) 1157else if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 1389if (_streams.TryGetValue(streamId, out var stream)) 1407void IHttp2StreamLifetimeHandler.OnStreamCompleted(Http2Stream stream) 1415Http2Stream? firstRequedStream = null; 1418while (_completedStreams.TryDequeue(out var stream)) 1456private void RemoveStream(Http2Stream stream) 1481while (_streams.Count >= maxStreams && _completedStreams.TryDequeue(out var stream))
Internal\Http2\Http2FrameWriter.cs (4)
187var stream = producer.Stream; 481private ValueTask<FlushResult> FlushEndOfStreamHeadersAsync(Http2Stream stream) 563private ValueTask<FlushResult> WriteDataAndTrailersAsync(Http2Stream stream, in ReadOnlySequence<byte> data, bool writeHeaders, HttpResponseTrailers headers) 781private ValueTask<FlushResult> WriteDataAsync(Http2Stream stream, ReadOnlySequence<byte> data, long dataLength, bool endStream, bool writeHeaders)
Internal\Http2\Http2MessageBody.cs (3)
17/// Owned by an <see cref="Http2Stream"/>. 23private readonly Http2Stream _context; 26public Http2MessageBody(Http2Stream context)
Internal\Http2\Http2OutputProducer.cs (4)
16/// Owned by <see cref="Http2Stream"/>. 30private readonly Http2Stream _stream; 60public Http2OutputProducer(Http2Stream stream, Http2StreamContext context) 80public Http2Stream Stream => _stream;
Internal\Http2\IHttp2StreamLifetimeHandler.cs (1)
8void OnStreamCompleted(Http2Stream stream);