Http3ControlStream

2 instantiations of Http3ControlStream

InMemory.FunctionalTests (2)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

403var stream = new Http3ControlStream(this, testStreamContext); 1065var stream = _testBase.OnCreateServerControlStream?.Invoke(testStreamContext) ?? new Http3ControlStream(_testBase, testStreamContext);

50 references to Http3ControlStream

InMemory.FunctionalTests (50)

Http3\Http3ConnectionTests.cs (9)

175var inboundControlStream = await Http3Api.GetInboundControlStream(); 200var inboundControlStream = await Http3Api.GetInboundControlStream(); 234var outboundcontrolStream = await Http3Api.CreateControlStream(); 277var controlStream = await Http3Api.CreateControlStream(); 295var controlStream = await Http3Api.CreateControlStream(id: 0); 320var controlStream = await Http3Api.CreateControlStream(id: 0); 342var controlStream = await Http3Api.GetInboundControlStream(); 362var inboundControlStream = await Http3Api.GetInboundControlStream(); 373var outboundcontrolStream = await Http3Api.CreateControlStream();

Http3\Http3StreamTests.cs (4)

2734var outboundControlStream = await Http3Api.CreateControlStream().DefaultTimeout(); 2737var inboundControlStream = await Http3Api.GetInboundControlStream(); 2741var invalidStream = await Http3Api.CreateControlStream(typeId).DefaultTimeout(); 2769var outboundcontrolStream = await Http3Api.CreateControlStream();

Http3\Http3TimeoutTests.cs (20)

25var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 41var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 64var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 98var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 131var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 172var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 219var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 222var outboundControlStream = await Http3Api.CreateControlStream(id: null); 254var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 257var outboundControlStream = await Http3Api.CreateControlStream(id: null); 283var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 289var outboundControlStream = await Http3Api.CreateControlStream(id: 0); 309var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 312var outboundControlStream = await Http3Api.CreateControlStream(id: null); 343var inboundControlStream = await Http3Api.GetInboundControlStream(); 382var inboundControlStream = await Http3Api.GetInboundControlStream(); 535var inboundControlStream = await Http3Api.GetInboundControlStream(); 580var inboundControlStream = await Http3Api.GetInboundControlStream(); 634var inboundControlStream = await Http3Api.GetInboundControlStream(); 694var inboundControlStream = await Http3Api.GetInboundControlStream();

Http3\WebTransport\WebTransportHandshakeTests.cs (4)

50var controlStream = await Http3Api.CreateControlStream(); 51var controlStream2 = await Http3Api.GetInboundControlStream(); 116var controlStream = await Http3Api.CreateControlStream(); 117var controlStream2 = await Http3Api.GetInboundControlStream();

Http3\WebTransport\WebTransportTestUtilities.cs (2)

47var controlStream = await inMemory.CreateControlStream(); 48var controlStream2 = await inMemory.GetInboundControlStream();

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (11)

85internal Func<TestStreamContext, Http3ControlStream> OnCreateServerControlStream { get; set; } 86private Http3ControlStream _inboundControlStream; 90internal Http3ControlStream OutboundControlStream { get; set; } 105internal async ValueTask<Http3ControlStream> GetInboundControlStream() 116while (reader.TryRead(out var stream)) 393internal ValueTask<Http3ControlStream> CreateControlStream() 398internal async ValueTask<Http3ControlStream> CreateControlStream(int? id) 403var stream = new Http3ControlStream(this, testStreamContext); 992public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.CreateUnbounded<Http3ControlStream>(new UnboundedChannelOptions 1065var stream = _testBase.OnCreateServerControlStream?.Invoke(testStreamContext) ?? new Http3ControlStream(_testBase, testStreamContext);