Http3ControlStream

2 instantiations of Http3ControlStream

InMemory.FunctionalTests (2)

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

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

50 references to Http3ControlStream

InMemory.FunctionalTests (50)

Http3\Http3ConnectionTests.cs (9)

173var inboundControlStream = await Http3Api.GetInboundControlStream(); 199var inboundControlStream = await Http3Api.GetInboundControlStream(); 234var outboundcontrolStream = await Http3Api.CreateControlStream(); 279var controlStream = await Http3Api.CreateControlStream(); 298var controlStream = await Http3Api.CreateControlStream(id: 0); 324var controlStream = await Http3Api.CreateControlStream(id: 0); 347var controlStream = await Http3Api.GetInboundControlStream(); 368var inboundControlStream = await Http3Api.GetInboundControlStream(); 379var outboundcontrolStream = await Http3Api.CreateControlStream();

Http3\Http3StreamTests.cs (4)

2758var outboundControlStream = await Http3Api.CreateControlStream().DefaultTimeout(); 2761var inboundControlStream = await Http3Api.GetInboundControlStream(); 2765var invalidStream = await Http3Api.CreateControlStream(typeId).DefaultTimeout(); 2793var outboundcontrolStream = await Http3Api.CreateControlStream();

Http3\Http3TimeoutTests.cs (20)

25var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 42var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 66var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 101var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 135var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 176var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 223var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 226var outboundControlStream = await Http3Api.CreateControlStream(id: null); 258var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 261var outboundControlStream = await Http3Api.CreateControlStream(id: null); 287var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 293var outboundControlStream = await Http3Api.CreateControlStream(id: 0); 313var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 316var outboundControlStream = await Http3Api.CreateControlStream(id: null); 347var inboundControlStream = await Http3Api.GetInboundControlStream(); 387var inboundControlStream = await Http3Api.GetInboundControlStream(); 541var inboundControlStream = await Http3Api.GetInboundControlStream(); 587var inboundControlStream = await Http3Api.GetInboundControlStream(); 642var inboundControlStream = await Http3Api.GetInboundControlStream(); 703var 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; } 107internal async ValueTask<Http3ControlStream> GetInboundControlStream() 118while (reader.TryRead(out var stream)) 398internal ValueTask<Http3ControlStream> CreateControlStream() 403internal async ValueTask<Http3ControlStream> CreateControlStream(int? id) 408var stream = new Http3ControlStream(this, testStreamContext); 997public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.CreateUnbounded<Http3ControlStream>(new UnboundedChannelOptions 1076var stream = _testBase.OnCreateServerControlStream?.Invoke(testStreamContext) ?? new Http3ControlStream(_testBase, testStreamContext);