2 types 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
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
Http2\Http2HttpProtocolFeatureCollectionTests.cs (1)
64private class TestHttp2Stream : Http2Stream
63 references to Http2Stream
InMemory.FunctionalTests (15)
Http2\Http2ConnectionTests.cs (7)
253Assert.True(_connection.StreamPool.TryPeek(out var stream1)); 271Assert.True(_connection.StreamPool.TryPeek(out var stream2)); 422var stream = _connection._streams[1]; 523var stream = _connection._streams[1]; 532Assert.True(_connection.StreamPool.TryPeek(out var pooledStream)); 594var stream = _connection._streams[1]; 698_connection.StreamPool.TryPeek(out var pooledStream);
Http2\Http2TestBase.cs (1)
531public void OnStreamCompleted(Http2Stream stream)
Http2\Http2WebSocketTests.cs (6)
185streamLifetimeHandler.Setup(o => o.OnStreamCompleted(It.IsAny<Http2Stream>())).Callback((Http2Stream stream) => 250Assert.True(_connection.StreamPool.TryPeek(out var pooledStream)); 624streamLifetimeHandler.Setup(o => o.OnStreamCompleted(It.IsAny<Http2Stream>())).Callback((Http2Stream stream) => 687Assert.True(_connection.StreamPool.TryPeek(out var pooledStream));
src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)
234public void OnStreamCompleted(Http2Stream stream)
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);
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (9)
PooledStreamStackTests.cs (8)
19var streams = new PooledStreamStack<Http2Stream>(10); 27var streams = new PooledStreamStack<Http2Stream>(10); 33Assert.Equal(1, ((Http2Stream)streams._array[0]).StreamId); 39var streams = new PooledStreamStack<Http2Stream>(10); 51var streams = new PooledStreamStack<Http2Stream>(10); 65var streams = new PooledStreamStack<Http2Stream>(10); 72Assert.Equal(2, ((Http2Stream)streams._array[0]).StreamId); 79var streams = new PooledStreamStack<Http2Stream>(5);
src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)
234public void OnStreamCompleted(Http2Stream stream)
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)
src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)
234public void OnStreamCompleted(Http2Stream stream)