1 instantiation of Http3RequestStream
InMemory.FunctionalTests (1)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
473return new Http3RequestStream(this, Connection, testStreamContext, headerHandler ?? new Http3RequestHeaderHandler());
103 references to Http3RequestStream
InMemory.FunctionalTests (103)
Http3\Http3ConnectionTests.cs (7)
155var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 178var request = await Http3Api.CreateRequestStream(Headers); 202var activeRequest = await Http3Api.CreateRequestStream(Headers); 210var rejectedRequest = await Http3Api.CreateRequestStream(Headers); 611var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 754var requestStream = await Http3Api.CreateRequestStream(Headers, endStream: true); 813var requestStream = await Http3Api.CreateRequestStream(headers, endStream: !sendData);
Http3\Http3StreamTests.cs (76)
35var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 56var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 79var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 97var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 115var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoMethod, headers, endStream: true); 138var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 152var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoMethod, headers, endStream: true); 169var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoPath, headers, endStream: true); 188var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoPath, headers, endStream: true); 208var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 243var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 267var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 284var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 303var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 328var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 346var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 366var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 387var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 410var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 433var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 456var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 478var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 498var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 518var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 539var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 558var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 587var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 622var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 658var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 692var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 722var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 763var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 797var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 830var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 860var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 894var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 931var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 954var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 986var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 1012var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1043var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1082var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1137var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1183var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1283var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1336var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1385var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1437var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1478var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1538var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1708var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1767var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1957var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null); 1983var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2013var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2056var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2097var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, null); 2128var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 2150var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, null); 2280var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2296var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2308var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2333var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_notImplementedApp, headers, endStream: true); 2406var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_notImplementedApp, headers, endStream: true); 2504var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2522var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2556var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2595var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2628var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2679var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2731var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2914var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 2954var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 2987var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 3009var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 3076var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c =>
Http3\Http3TimeoutTests.cs (13)
68var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 103var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 133var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null).DefaultTimeout(); 174var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null).DefaultTimeout(); 351var requestStream = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_helloWorldBytes.Length), endStream: false); 459var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(app.RunApp, _browserRequestHeaders, endStream: false); 501var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(app.RunApp, _browserRequestHeaders, endStream: false); 545var requestStream = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 591var requestStream1 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 597var requestStream2 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 648var requestStream1 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 657var requestStream2 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 709var requestStream = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_helloWorldBytes.Length), endStream: false);
Http3\WebTransport\WebTransportHandshakeTests.cs (1)
138var requestStream = await Http3Api.CreateRequestStream(headersConnectFrame);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (6)
268internal async ValueTask<Http3RequestStream> InitializeConnectionAndStreamsAsync(RequestDelegate application, IEnumerable<KeyValuePair<string, string>> headers, bool endStream = false) 419internal async ValueTask<Http3RequestStream> CreateRequestStream(IEnumerable<KeyValuePair<string, string>> headers, 422var stream = CreateRequestStreamCore(headerHandler, clientWriterScheduler); 441internal async ValueTask<Http3RequestStream> CreateRequestStream(Http3HeadersEnumerator headers, Http3RequestHeaderHandler headerHandler = null, 444var stream = CreateRequestStreamCore(headerHandler, clientWriterScheduler); 460private Http3RequestStream CreateRequestStreamCore(Http3RequestHeaderHandler headerHandler, PipeScheduler clientWriterScheduler)