1 type derived from Http2Stream
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http2\Http2StreamOfT.cs (1)
10internal sealed class Http2Stream<TContext> : Http2Stream, IHostContextContainer<TContext> where TContext : notnull
34 references to Http2Stream
Microsoft.AspNetCore.Server.Kestrel.Core (34)
Internal\Http2\FlowControl\StreamInputFlowControl.cs (2)
14private readonly Http2Stream _stream; 18Http2Stream stream,
Internal\Http2\Http2Connection.cs (22)
105private Http2Stream? _currentHeadersStream; 123private readonly ConcurrentQueue<Http2Stream> _completedStreams = new ConcurrentQueue<Http2Stream>(); 130internal readonly Dictionary<int, Http2Stream> _streams = new Dictionary<int, Http2Stream>(); 131internal PooledStreamStack<Http2Stream> StreamPool; 170StreamPool = new PooledStreamStack<Http2Stream>(Math.Min(InitialStreamPoolSize, http2Limits.MaxStreamsPerConnection)); 405foreach (var stream in _streams.Values) 424while (StreamPool.TryPop(out var pooledStream)) 670if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 729if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 797private Http2Stream GetStream<TContext>(IHttpApplication<TContext> application) where TContext : notnull 799if (StreamPool.TryPop(out var stream)) 879if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 949foreach (var stream in _streams.Values) 1072else if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 1304if (_streams.TryGetValue(streamId, out var stream)) 1322void IHttp2StreamLifetimeHandler.OnStreamCompleted(Http2Stream stream) 1330Http2Stream? firstRequedStream = null; 1333while (_completedStreams.TryDequeue(out var stream)) 1371private void RemoveStream(Http2Stream stream) 1396while (_streams.Count >= maxStreams && _completedStreams.TryDequeue(out var stream))
Internal\Http2\Http2FrameWriter.cs (4)
167var stream = producer.Stream; 420private ValueTask<FlushResult> FlushEndOfStreamHeadersAsync(Http2Stream stream) 501private ValueTask<FlushResult> WriteDataAndTrailersAsync(Http2Stream stream, in ReadOnlySequence<byte> data, bool writeHeaders, HttpResponseTrailers headers) 649private ValueTask<FlushResult> WriteDataAsync(Http2Stream stream, ReadOnlySequence<byte> data, long dataLength, bool endStream, bool writeHeaders)
Internal\Http2\Http2MessageBody.cs (2)
15private readonly Http2Stream _context; 18public Http2MessageBody(Http2Stream context)
Internal\Http2\Http2OutputProducer.cs (3)
23private readonly Http2Stream _stream; 53public Http2OutputProducer(Http2Stream stream, Http2StreamContext context) 73public Http2Stream Stream => _stream;
Internal\Http2\IHttp2StreamLifetimeHandler.cs (1)
8void OnStreamCompleted(Http2Stream stream);