1 instantiation of Http3RequestStream
InMemory.FunctionalTests (1)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
471return new Http3RequestStream(this, Connection, testStreamContext, headerHandler ?? new Http3RequestHeaderHandler());
102 references to Http3RequestStream
InMemory.FunctionalTests (102)
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); 582var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 725var requestStream = await Http3Api.CreateRequestStream(Headers, endStream: true); 784var requestStream = await Http3Api.CreateRequestStream(headers, endStream: !sendData);
Http3\Http3StreamTests.cs (75)
33var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 54var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 77var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 95var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 113var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoMethod, headers, endStream: true); 136var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 150var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoMethod, headers, endStream: true); 167var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoPath, headers, endStream: true); 186var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoPath, headers, endStream: true); 206var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 241var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 265var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 282var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 301var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 326var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 344var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 364var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 385var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 408var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 431var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 454var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoHost, headers, endStream: true); 476var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 496var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 516var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 537var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 556var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 585var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 620var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 656var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 690var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 720var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 761var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 795var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 828var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 858var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 892var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 929var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 952var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 984var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 1010var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1041var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1080var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1135var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1181var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1281var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1334var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1383var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1435var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1476var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1536var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1706var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1765var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1955var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null); 1981var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2011var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2054var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2095var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, null); 2126var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 2148var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, null); 2278var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2294var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2306var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2331var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_notImplementedApp, headers, endStream: true); 2389var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_notImplementedApp, headers, endStream: true); 2487var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, headers, endStream: true); 2505var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2539var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2578var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2611var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2662var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2714var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 2897var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 2937var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 2970var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(c => 2992var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context =>
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, Http3RequestHeaderHandler headerHandler = null, bool endStream = false, TaskCompletionSource tsc = null) 421var stream = CreateRequestStreamCore(headerHandler); 440internal async ValueTask<Http3RequestStream> CreateRequestStream(Http3HeadersEnumerator headers, Http3RequestHeaderHandler headerHandler = null, bool endStream = false, TaskCompletionSource tsc = null) 442var stream = CreateRequestStreamCore(headerHandler); 458private Http3RequestStream CreateRequestStreamCore(Http3RequestHeaderHandler headerHandler)