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