2 instantiations of Http3ControlStream
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (2)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)
421var stream = new Http3ControlStream(this, testStreamContext); 1097var stream = _testBase.OnCreateServerControlStream?.Invoke(testStreamContext) ?? new Http3ControlStream(_testBase, testStreamContext);
11 references to Http3ControlStream
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (11)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (11)
84internal Func<TestStreamContext, Http3ControlStream> OnCreateServerControlStream { get; set; } 85private Http3ControlStream _inboundControlStream; 89internal Http3ControlStream OutboundControlStream { get; set; } 106internal async ValueTask<Http3ControlStream> GetInboundControlStream() 117while (reader.TryRead(out var stream)) 411internal ValueTask<Http3ControlStream> CreateControlStream(PipeScheduler clientWriterScheduler = null) 416internal async ValueTask<Http3ControlStream> CreateControlStream(int? id, PipeScheduler clientWriterScheduler = null) 421var stream = new Http3ControlStream(this, testStreamContext); 1014public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.CreateUnbounded<Http3ControlStream>(new UnboundedChannelOptions 1097var stream = _testBase.OnCreateServerControlStream?.Invoke(testStreamContext) ?? new Http3ControlStream(_testBase, testStreamContext);