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)
126private Http2Stream? _currentHeadersStream; 144private readonly ConcurrentQueue<Http2Stream> _completedStreams = new ConcurrentQueue<Http2Stream>(); 152internal readonly Dictionary<int, Http2Stream> _streams = new Dictionary<int, Http2Stream>(); 153internal PooledStreamStack<Http2Stream> StreamPool; 193StreamPool = new PooledStreamStack<Http2Stream>(Math.Min(InitialStreamPoolSize, http2Limits.MaxStreamsPerConnection)); 459foreach (var stream in _streams.Values) 478while (StreamPool.TryPop(out var pooledStream)) 727if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 764private Http2ConnectionErrorException CreateReceivedFrameStreamAbortedException(Http2Stream stream) 812if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 892private Http2Stream GetStream<TContext>(IHttpApplication<TContext> application) where TContext : notnull 894if (StreamPool.TryPop(out var stream)) 974if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 1046foreach (var stream in _streams.Values) 1173else if (_streams.TryGetValue(_incomingFrame.StreamId, out var stream)) 1423if (_streams.TryGetValue(streamId, out var stream)) 1441void IHttp2StreamLifetimeHandler.OnStreamCompleted(Http2Stream stream) 1449Http2Stream? firstRequedStream = null; 1452while (_completedStreams.TryDequeue(out var stream)) 1490private void RemoveStream(Http2Stream stream) 1515while (_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);