1 instantiation of Http3RequestStream
InMemory.FunctionalTests (1)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
466return new Http3RequestStream(this, Connection, testStreamContext, headerHandler ?? new Http3RequestHeaderHandler());
101 references to Http3RequestStream
InMemory.FunctionalTests (101)
Http3\Http3ConnectionTests.cs (6)
157var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 180var request = await Http3Api.CreateRequestStream(Headers); 203var activeRequest = await Http3Api.CreateRequestStream(Headers); 211var rejectedRequest = await Http3Api.CreateRequestStream(Headers); 576var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 594var requestStream = await Http3Api.CreateRequestStream(headers, endStream: !sendData);
Http3\Http3StreamTests.cs (75)
38var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 59var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 82var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 100var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 118var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoMethod, headers, endStream: true); 141var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 155var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoMethod, headers, endStream: true); 172var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoPath, headers, endStream: true); 191var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoPath, headers, endStream: true); 211var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 246var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 270var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 287var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 306var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 331var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 349var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 369var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 390var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 413var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 436var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 459var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 481var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 501var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 521var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 542var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 561var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 590var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 625var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 661var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 695var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 725var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 766var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 800var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 833var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 863var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 897var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 934var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 957var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 989var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 1015var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1046var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1085var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1140var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1186var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1286var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1339var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1388var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1440var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1481var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1541var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1711var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1770var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1960var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null); 1986var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2016var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2052var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2093var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, null); 2123var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 2138var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, null); 2268var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2284var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2296var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2321var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_notImplementedApp, headers, endStream: true); 2379var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_notImplementedApp, headers, endStream: true); 2463var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2481var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2515var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2554var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2587var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2638var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2690var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2873var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 2913var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 2946var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 2968var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context =>
Http3\Http3TimeoutTests.cs (13)
66var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 100var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 129var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null).DefaultTimeout(); 170var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null).DefaultTimeout(); 347var requestStream = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_helloWorldBytes.Length), endStream: false); 453var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(app.RunApp, _browserRequestHeaders, endStream: false); 495var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(app.RunApp, _browserRequestHeaders, endStream: false); 539var requestStream = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 584var requestStream1 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 590var requestStream2 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 640var requestStream1 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 649var requestStream2 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 700var 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)
263internal async ValueTask<Http3RequestStream> InitializeConnectionAndStreamsAsync(RequestDelegate application, IEnumerable<KeyValuePair<string, string>> headers, bool endStream = false) 414internal async ValueTask<Http3RequestStream> CreateRequestStream(IEnumerable<KeyValuePair<string, string>> headers, Http3RequestHeaderHandler headerHandler = null, bool endStream = false, TaskCompletionSource tsc = null) 416var stream = CreateRequestStreamCore(headerHandler); 435internal async ValueTask<Http3RequestStream> CreateRequestStream(Http3HeadersEnumerator headers, Http3RequestHeaderHandler headerHandler = null, bool endStream = false, TaskCompletionSource tsc = null) 437var stream = CreateRequestStreamCore(headerHandler); 453private Http3RequestStream CreateRequestStreamCore(Http3RequestHeaderHandler headerHandler)