126Http3Api = new Http3InMemory(_serviceContext, _serviceContext.FakeTimeProvider, _mockTimeoutHandler.Object, LoggerFactory);

39await Http3Api.InitializeConnectionAsync(async context => 52await Http3Api.CreateControlStream(); 53await Http3Api.GetInboundControlStream(); 55var requestStream = await Http3Api.CreateRequestStream(new[] 79await Http3Api.InitializeConnectionAsync(async context => 90await Http3Api.CreateControlStream(); 91await Http3Api.GetInboundControlStream(); 93var requestStream = await Http3Api.CreateRequestStream(new[] 139await Http3Api.InitializeConnectionAsync(async context => 153await Http3Api.CreateControlStream(); 154await Http3Api.GetInboundControlStream(); 155var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 171await Http3Api.InitializeConnectionAsync(_echoApplication); 173var inboundControlStream = await Http3Api.GetInboundControlStream(); 178var request = await Http3Api.CreateRequestStream(Headers); 186Http3Api.CloseServerGracefully(); 188Assert.Null(await Http3Api.MultiplexedConnectionContext.AcceptAsync().DefaultTimeout()); 190await Http3Api.WaitForConnectionStopAsync(expectedStreamId, false, expectedErrorCode: Http3ErrorCode.NoError); 191MetricsAssert.NoError(Http3Api.ConnectionTags); 197await Http3Api.InitializeConnectionAsync(_echoApplication); 199var inboundControlStream = await Http3Api.GetInboundControlStream(); 202var activeRequest = await Http3Api.CreateRequestStream(Headers); 205Http3Api.CloseServerGracefully(); 207await Http3Api.WaitForGoAwayAsync(false, VariableLengthIntegerHelper.EightByteLimit); 210var rejectedRequest = await Http3Api.CreateRequestStream(Headers); 218Http3Api.MultiplexedConnectionContext.Abort(); 220await Http3Api.WaitForConnectionStopAsync(4, false, expectedErrorCode: Http3ErrorCode.NoError); 221MetricsAssert.NoError(Http3Api.ConnectionTags); 232await Http3Api.InitializeConnectionAsync(_echoApplication); 234var outboundcontrolStream = await Http3Api.CreateControlStream(); 240await Http3Api.GetInboundControlStream(); 242await Http3Api.WaitForConnectionErrorAsync<Http3ConnectionErrorException>( 248MetricsAssert.Equal(ConnectionEndReason.InvalidSettings, Http3Api.ConnectionTags); 257await Http3Api.InitializeConnectionAsync(_noopApplication); 259await Http3Api.CreateControlStream(streamId); 260await Http3Api.CreateControlStream(streamId); 262await Http3Api.WaitForConnectionErrorAsync<Http3ConnectionErrorException>( 268MetricsAssert.Equal(ConnectionEndReason.StreamCreationError, Http3Api.ConnectionTags); 277await Http3Api.InitializeConnectionAsync(_noopApplication); 279var controlStream = await Http3Api.CreateControlStream(); 284await Http3Api.WaitForConnectionErrorAsync<Http3ConnectionErrorException>( 290MetricsAssert.Equal(ConnectionEndReason.UnexpectedFrame, Http3Api.ConnectionTags); 296await Http3Api.InitializeConnectionAsync(_noopApplication); 298var controlStream = await Http3Api.CreateControlStream(id: 0); 306Http3Api.TriggerTick(); 307Http3Api.TriggerTick(TimeSpan.FromSeconds(1)); 309await Http3Api.WaitForConnectionErrorAsync<Http3ConnectionErrorException>( 315MetricsAssert.Equal(ConnectionEndReason.ClosedCriticalStream, Http3Api.ConnectionTags); 322await Http3Api.InitializeConnectionAsync(_noopApplication); 324var controlStream = await Http3Api.CreateControlStream(id: 0); 326var lifetime = Http3Api.MultiplexedConnectionContext.Features.Get<IConnectionLifetimeNotificationFeature>(); 336Http3Api.CloseServerGracefully(); 338await Http3Api.WaitForConnectionStopAsync(0, true, expectedErrorCode: Http3ErrorCode.NoError); 339MetricsAssert.NoError(Http3Api.ConnectionTags); 345await Http3Api.InitializeConnectionAsync(_noopApplication); 347var controlStream = await Http3Api.GetInboundControlStream(); 351Http3Api.TriggerTick(); 352Http3Api.TriggerTick(TimeSpan.FromSeconds(1)); 354await Http3Api.WaitForConnectionErrorAsync<Http3ConnectionErrorException>( 360MetricsAssert.Equal(ConnectionEndReason.ClosedCriticalStream, Http3Api.ConnectionTags); 371await Http3Api.InitializeConnectionAsync(_noopApplication); 373var controlStream = await Http3Api.CreateControlStream(); 383await Http3Api.WaitForConnectionErrorAsync<Http3ConnectionErrorException>( 389MetricsAssert.Equal(ConnectionEndReason.InvalidFrameLength, Http3Api.ConnectionTags); 395await Http3Api.InitializeConnectionAsync(_echoApplication); 397var inboundControlStream = await Http3Api.GetInboundControlStream(); 408var outboundcontrolStream = await Http3Api.CreateControlStream(); 414var maxFieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 431await Http3Api.InitializeConnectionAsync(_echoApplication); 453await Http3Api.InitializeConnectionAsync(async context => 498await Http3Api.InitializeConnectionAsync(_echoApplication); 532await Http3Api.InitializeConnectionAsync(_echoApplication); 568await Http3Api.InitializeConnectionAsync(requestDelegate); 593await Http3Api.InitializeConnectionAsync(context => 611var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 631await Http3Api.InitializeConnectionAsync(async c => 659var requestStream = await Http3Api.CreateRequestStream(new[] 683await Http3Api.InitializeConnectionAsync(async c => 713var requestStream = await Http3Api.CreateRequestStream(new[] 749Http3Api.MultiplexedConnectionContext = new ThrowingMultiplexedConnectionContext(Http3Api, skipCount: 2, requestTcs, abortTcs); 750await Http3Api.InitializeConnectionAsync(_echoApplication); 752await Http3Api.CreateControlStream(); 753await Http3Api.GetInboundControlStream(); 754var requestStream = await Http3Api.CreateRequestStream(Headers, endStream: true); 765Http3Api.CloseServerGracefully(); 767var errorCodeFeature = Http3Api.MultiplexedConnectionContext.Features.Get<IProtocolErrorCodeFeature>(); 813var requestStream = await Http3Api.CreateRequestStream(headers, endStream: !sendData);

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 => 1109var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(context => 1137var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1183var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1235var 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 => 1593var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1651var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1708var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1767var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1831var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1894var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async context => 1955Http3Api._serviceContext.ServerOptions.EnableWebTransportAndH3Datagrams = pendingStreamsEnabled; 1957var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null); 1983var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2013var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2033await Http3Api.WaitForConnectionErrorAsync<ConnectionAbortedException>( 2038MetricsAssert.Equal(ConnectionEndReason.UnexpectedFrame, Http3Api.ConnectionTags); 2056var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 2095Http3Api._serviceContext.ServerOptions.EnableWebTransportAndH3Datagrams = pendingStreamsEnabled; 2097var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, null); 2108await Http3Api.WaitForConnectionErrorAsync<Http3ConnectionErrorException>( 2114MetricsAssert.Equal(ConnectionEndReason.UnexpectedFrame, Http3Api.ConnectionTags); 2128var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_echoApplication, headers); 2139await Http3Api.WaitForConnectionErrorAsync<ConnectionAbortedException>( 2144MetricsAssert.Equal(ConnectionEndReason.UnexpectedFrame, Http3Api.ConnectionTags); 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 => 2773await Http3Api.InitializeConnectionAsync(_noopApplication); 2775var outboundControlStream = await Http3Api.CreateControlStream().DefaultTimeout(); 2778var inboundControlStream = await Http3Api.GetInboundControlStream(); 2782var invalidStream = await Http3Api.CreateControlStream(typeId).DefaultTimeout(); 2789var requestStream = await Http3Api.CreateRequestStream(new[] 2804await Http3Api.InitializeConnectionAsync(context => 2810var outboundcontrolStream = await Http3Api.CreateControlStream(); 2816var maxFieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 2821var requestStream = await Http3Api.CreateRequestStream(new[] 2842var 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 => 3024await Http3Api.InitializeConnectionAsync(_noopApplication); 3026var outboundcontrolStream = await Http3Api.CreateControlStream(); 3036await Http3Api.InitializeConnectionAsync(_noopApplication); 3038var outboundcontrolStream = await Http3Api.CreateControlStream(); 3076var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(async c => 3111await Http3Api.InitializeConnectionAsync(async context => 3139var stream = await Http3Api.CreateRequestStream(headers: [], clientWriterScheduler: PipeScheduler.Inline); 3219await Http3Api.InitializeConnectionAsync(_noopApplication); 3223var outboundcontrolStream = await Http3Api.CreateControlStream(clientWriterScheduler: PipeScheduler.Inline); 3246var fieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 3251fieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 3255fieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 3288Http3Api.MultiplexedConnectionContext.ConnectionClosed.Register(() => tcs.TrySetResult());

23await Http3Api.InitializeConnectionAsync(_noopApplication).DefaultTimeout(); 25var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 28Http3Api.AdvanceTime(limits.KeepAliveTimeout + TimeSpan.FromTicks(1)); 30await Http3Api.WaitForConnectionStopAsync(0, false, expectedErrorCode: Http3ErrorCode.NoError); 31MetricsAssert.Equal(ConnectionEndReason.KeepAliveTimeout, Http3Api.ConnectionTags); 39await Http3Api.InitializeConnectionAsync(_noopApplication).DefaultTimeout(); 40await Http3Api.CreateControlStream(); 42var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 45Http3Api.AdvanceTime(limits.KeepAliveTimeout + TimeSpan.FromTicks(1)); 47await Http3Api.WaitForConnectionStopAsync(0, false, expectedErrorCode: Http3ErrorCode.NoError); 48MetricsAssert.Equal(ConnectionEndReason.KeepAliveTimeout, Http3Api.ConnectionTags); 63await Http3Api.InitializeConnectionAsync(_noopApplication).DefaultTimeout(); 65await Http3Api.CreateControlStream(); 66var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 68var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 74Http3Api.AdvanceTime(limits.KeepAliveTimeout + Heartbeat.Interval + TimeSpan.FromTicks(1)); 76await Http3Api.WaitForConnectionStopAsync(4, false, expectedErrorCode: Http3ErrorCode.NoError); 77MetricsAssert.Equal(ConnectionEndReason.KeepAliveTimeout, Http3Api.ConnectionTags); 94await Http3Api.InitializeConnectionAsync(_ => 100await Http3Api.CreateControlStream(); 101var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 103var requestStream = await Http3Api.CreateRequestStream(requestHeaders, endStream: true); 107Http3Api.AdvanceTime(limits.KeepAliveTimeout); 108Http3Api.AdvanceTime(limits.KeepAliveTimeout); 109Http3Api.AdvanceTime(limits.KeepAliveTimeout); 110Http3Api.AdvanceTime(limits.KeepAliveTimeout); 111Http3Api.AdvanceTime(limits.KeepAliveTimeout); 120Http3Api.AdvanceTime(limits.KeepAliveTimeout + Heartbeat.Interval + TimeSpan.FromTicks(1)); 122await Http3Api.WaitForConnectionStopAsync(4, false, expectedErrorCode: Http3ErrorCode.NoError); 123MetricsAssert.Equal(ConnectionEndReason.KeepAliveTimeout, Http3Api.ConnectionTags); 133var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null).DefaultTimeout(); 135var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 142var serverRequestStream = Http3Api.Connection._streams[requestStream.StreamId]; 144Http3Api.TriggerTick(); 145Http3Api.TriggerTick(limits.RequestHeadersTimeout); 149Http3Api.TriggerTick(TimeSpan.FromTicks(1)); 162Http3Api._serviceContext.ServerOptions.EnableWebTransportAndH3Datagrams = pendingStreamsEnabled; 174var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(_noopApplication, null).DefaultTimeout(); 176var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 185serverRequestStream = Http3Api.Connection._unidentifiedStreams[requestStream.StreamId]; 191serverRequestStream = Http3Api.Connection._streams[requestStream.StreamId]; 194Http3Api.TriggerTick(); 195Http3Api.AdvanceTime(limits.RequestHeadersTimeout); 203Http3Api.AdvanceTime(TimeSpan.FromTicks(1)); 215Http3Api._serviceContext.ServerOptions.EnableWebTransportAndH3Datagrams = true; 221await Http3Api.InitializeConnectionAsync(_noopApplication).DefaultTimeout(); 223var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 226var outboundControlStream = await Http3Api.CreateControlStream(id: null); 229var serverInboundControlStream = Http3Api.Connection._unidentifiedStreams[outboundControlStream.StreamId]; 231Http3Api.TriggerTick(); 232Http3Api.AdvanceTime(limits.RequestHeadersTimeout); 236Http3Api.AdvanceTime(TimeSpan.FromTicks(1)); 242Http3Api._serviceContext.ServerOptions.EnableWebTransportAndH3Datagrams = false; 246Http3Api._timeoutControl.Initialize(); 256await Http3Api.InitializeConnectionAsync(_noopApplication).DefaultTimeout(); 258var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 261var outboundControlStream = await Http3Api.CreateControlStream(id: null); 265var serverInboundControlStream = Http3Api.Connection._streams[outboundControlStream.StreamId]; 267Http3Api.TriggerTick(); 268Http3Api.TriggerTick(limits.RequestHeadersTimeout); 272Http3Api.TriggerTick(TimeSpan.FromTicks(1)); 285await Http3Api.InitializeConnectionAsync(_noopApplication).DefaultTimeout(); 287var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 290Http3Api.TriggerTick(); 291Http3Api.TriggerTick(limits.RequestHeadersTimeout + TimeSpan.FromTicks(1)); 293var outboundControlStream = await Http3Api.CreateControlStream(id: 0); 297Http3Api.TriggerTick(); 305Http3Api._serviceContext.ServerOptions.EnableWebTransportAndH3Datagrams = pendingStreamEnabled; 311await Http3Api.InitializeConnectionAsync(_noopApplication).DefaultTimeout(); 313var controlStream = await Http3Api.GetInboundControlStream().DefaultTimeout(); 316var outboundControlStream = await Http3Api.CreateControlStream(id: null); 322serverInboundControlStream = Http3Api.Connection._unidentifiedStreams[outboundControlStream.StreamId]; 327serverInboundControlStream = Http3Api.Connection._streams[outboundControlStream.StreamId]; 330Http3Api.TriggerTick(); 343Http3Api._timeoutControl.Initialize(); 345await Http3Api.InitializeConnectionAsync(_readRateApplication); 347var inboundControlStream = await Http3Api.GetInboundControlStream(); 351var requestStream = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_helloWorldBytes.Length), endStream: false); 359Http3Api.AdvanceTime(limits.MinRequestBodyDataRate.GracePeriod); 363Http3Api.AdvanceTime(TimeSpan.FromTicks(1)); 367await Http3Api.WaitForConnectionErrorAsync<ConnectionAbortedException>( 372MetricsAssert.Equal(ConnectionEndReason.MinRequestBodyDataRate, Http3Api.ConnectionTags); 385await Http3Api.InitializeConnectionAsync(_noopApplication); 387var inboundControlStream = await Http3Api.GetInboundControlStream(); 390var requestStream = await Http3Api.CreateRequestStream(new[] 400Http3Api.TriggerTick(); 403Http3Api.TriggerTick(TimeSpan.FromTicks(1)); 406Http3Api.TriggerTick(limits.MinResponseDataRate.GracePeriod); 410await Http3Api.WaitForConnectionErrorAsync<Http3ConnectionErrorException>( 416MetricsAssert.Equal(ConnectionEndReason.MinResponseDataRate, Http3Api.ConnectionTags); 456Http3Api._timeoutControl.Initialize(); 459var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(app.RunApp, _browserRequestHeaders, endStream: false); 467Http3Api._timeoutControl.Tick(fakeTimeProvider.GetTimestamp()); 470Http3Api.AdvanceTime(TimeSpan.FromSeconds((requestStream.BytesReceived + _helloWorldBytes.Length) / limits.MinResponseDataRate.BytesPerSecond) + 475Http3Api.AdvanceTime(TimeSpan.FromSeconds(1)); 498Http3Api._timeoutControl.Initialize(); 501var requestStream = await Http3Api.InitializeConnectionAndStreamsAsync(app.RunApp, _browserRequestHeaders, endStream: false); 509Http3Api._timeoutControl.Tick(fakeTimeProvider.GetTimestamp()); 515Http3Api.AdvanceTime(timeToWriteMaxData); 519Http3Api.AdvanceTime(TimeSpan.FromSeconds(1)); 537Http3Api._timeoutControl.Initialize(); 539await Http3Api.InitializeConnectionAsync(_readRateApplication); 541var inboundControlStream = await Http3Api.GetInboundControlStream(); 545var requestStream = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 557Http3Api.AdvanceTime(timeToReadMaxData); 561Http3Api.AdvanceTime(TimeSpan.FromSeconds(1)); 565await Http3Api.WaitForConnectionErrorAsync<ConnectionAbortedException>( 570MetricsAssert.Equal(ConnectionEndReason.MinRequestBodyDataRate, Http3Api.ConnectionTags); 583Http3Api._timeoutControl.Initialize(); 585await Http3Api.InitializeConnectionAsync(_readRateApplication); 587var inboundControlStream = await Http3Api.GetInboundControlStream(); 591var requestStream1 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 597var requestStream2 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 612Http3Api.AdvanceTime(timeToReadMaxData); 616Http3Api.AdvanceTime(TimeSpan.FromSeconds(1)); 620await Http3Api.WaitForConnectionErrorAsync<ConnectionAbortedException>( 625MetricsAssert.Equal(ConnectionEndReason.MinRequestBodyDataRate, Http3Api.ConnectionTags); 638Http3Api._timeoutControl.Initialize(); 640await Http3Api.InitializeConnectionAsync(_readRateApplication); 642var inboundControlStream = await Http3Api.GetInboundControlStream(); 648var requestStream1 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 657var requestStream2 = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_maxData.Length), endStream: false); 668Http3Api.AdvanceTime(timeToReadMaxData); 672Http3Api.AdvanceTime(TimeSpan.FromSeconds(1)); 676await Http3Api.WaitForConnectionErrorAsync<ConnectionAbortedException>( 681MetricsAssert.Equal(ConnectionEndReason.MinRequestBodyDataRate, Http3Api.ConnectionTags); 694Http3Api._timeoutControl.Initialize(); 696await Http3Api.InitializeConnectionAsync(context => 703var inboundControlStream = await Http3Api.GetInboundControlStream(); 706Http3Api.OutboundControlStream = await Http3Api.CreateControlStream(); 709var requestStream = await Http3Api.CreateRequestStream(ReadRateRequestHeaders(_helloWorldBytes.Length), endStream: false); 717Http3Api.AdvanceTime(limits.MinRequestBodyDataRate.GracePeriod); 721Http3Api.AdvanceTime(TimeSpan.FromTicks(1));

26await Http3Api.InitializeConnectionAsync(async context => 50var controlStream = await Http3Api.CreateControlStream(); 51var controlStream2 = await Http3Api.GetInboundControlStream(); 62await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 66var requestStream = await Http3Api.CreateRequestStream(new[] 115await Http3Api.InitializeConnectionAsync(_noopApplication); 116var controlStream = await Http3Api.CreateControlStream(); 117var controlStream2 = await Http3Api.GetInboundControlStream(); 128await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 138var requestStream = await Http3Api.CreateRequestStream(headersConnectFrame);

15Http3Api._serviceContext.ServerOptions.EnableWebTransportAndH3Datagrams = true; 19var session = await WebTransportTestUtilities.GenerateSession(Http3Api, exitTcs); 36Http3Api._serviceContext.ServerOptions.EnableWebTransportAndH3Datagrams = true; // TODO add more sync code as now it is flaky 39var session = await WebTransportTestUtilities.GenerateSession(Http3Api, exitTcs); 71Http3Api._serviceContext.ServerOptions.EnableWebTransportAndH3Datagrams = true; 74var session = await WebTransportTestUtilities.GenerateSession(Http3Api, exitTcs); 88Http3Api.Connection._streams[session.SessionId].Abort(new(), System.Net.Http.Http3ErrorCode.InternalError);