494_connection = new Http2Connection(httpConnectionContext);

36_connection.ServerSettings.MaxConcurrentStreams = 2; 195Assert.Equal(1, _connection.StreamPool.Count); 252Assert.Equal(1, _connection.StreamPool.Count); 253Assert.True(_connection.StreamPool.TryPeek(out var stream1)); 270Assert.Equal(1, _connection.StreamPool.Count); 271Assert.True(_connection.StreamPool.TryPeek(out var stream2)); 371Assert.Equal(1, _connection.StreamPool.Count); 416Assert.Equal(0, _connection.StreamPool.Count); 422var stream = _connection._streams[1]; 431Assert.Equal(1, _connection.StreamPool.Count); 447Assert.Equal(0, _connection.StreamPool.Count); 488Assert.Equal(2, _connection.StreamPool.Count); 515Assert.Equal(0, _connection.StreamPool.Count); 525var stream = _connection._streams[1]; 535Assert.Equal(1, _connection.StreamPool.Count); 536Assert.True(_connection.StreamPool.TryPeek(out var pooledStream)); 554Assert.Equal(0, _connection.StreamPool.Count); 564Assert.Equal(1, _connection.StreamPool.Count); 565Assert.True(_connection.StreamPool.TryPeek(out pooledStream)); 600var stream = _connection._streams[1]; 613Assert.Equal(0, _connection.StreamPool.Count); 633_connection.ServerSettings.MaxConcurrentStreams = 1; 645Assert.Equal(0, _connection.StreamPool.Count); 658_connection.ServerSettings.MaxConcurrentStreams = 1; 675Assert.Equal(0, _connection.StreamPool.Count); 689Assert.Equal(0, _connection.StreamPool.Count); 704Assert.Equal(1, _connection.StreamPool.Count); 706_connection.StreamPool.TryPeek(out var pooledStream); 711Assert.Equal(1, _connection.StreamPool.Count); 716Assert.Equal(0, _connection.StreamPool.Count); 1687Assert.Equal((uint)100, _connection.MaxTrackedStreams); 1700Assert.Equal((uint)200, _connection.MaxTrackedStreams); 1713Assert.Equal((uint)int.MaxValue * 2, _connection.MaxTrackedStreams); 1725Assert.Equal(100u, _connection.MaxTrackedStreams); 1726_connection.Abort(new ConnectionAbortedException(), ConnectionEndReason.AbortedByApp); 1751_connection.SendEnhanceYourCalmOnStartStream = true; 2052_connection.HandleReadDataRateTimeout(); 2511_connection.ServerSettings.MaxConcurrentStreams = 1; 3651_connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)); 3703_connection.ServerSettings.HeaderTableSize = 0; 3704_connection.ServerSettings.MaxConcurrentStreams = 1; 3705_connection.ServerSettings.MaxHeaderListSize = 4 * 1024; 3706_connection.ServerSettings.InitialWindowSize = 1024 * 1024 * 10; 3708_connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)); 3911_connection.ServerSettings.MaxFrameSize = Http2PeerSettings.MaxAllowedMaxFrameSize; 3972_connection.ServerSettings.MaxFrameSize = Http2PeerSettings.MinAllowedMaxFrameSize + 1024; 4182var lifetime = _connection.ConnectionFeatures.Get<IConnectionLifetimeNotificationFeature>(); 5145_connection.OnInputOrOutputCompleted(); 5160_connection.Abort(new ConnectionAbortedException(), ConnectionEndReason.AbortedByApp); 5235_connection.StopProcessingNextRequest(ConnectionEndReason.AppShutdownTimeout); 5268_connection.StopProcessingNextRequest(ConnectionEndReason.AppShutdownTimeout); 5320_connection.OnInputOrOutputCompleted(); 5340await _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)).DefaultTimeout(); 5360await _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)).DefaultTimeout(); 5527_connection.ServerSettings.MaxConcurrentStreams = 0; // Refuse all streams 5529var connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)); 5609_connection.ServerSettings.MaxConcurrentStreams = 1; 5611var connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_ => requestBlock.Task)); 5682_connection.ServerSettings.MaxConcurrentStreams = 1; 5893await SendAsync(Encoding.ASCII.GetBytes($"GET /{new string('a', _connection.Limits.MaxRequestLineSize)} HTTP/1.1\r\n")); 5910_connection.ConnectionFeatures.Set<ITlsHandshakeFeature>(tlsHandshakeMock.Object);

18Assert.Null(_connection._keepAlive); 48Assert.Equal(KeepAliveState.PingSent, _connection._keepAlive._state); 202Assert.Equal(KeepAliveState.Timeout, _connection._keepAlive._state); 223Assert.Equal(KeepAliveState.PingSent, _connection._keepAlive._state); 230Assert.Equal(KeepAliveState.None, _connection._keepAlive._state);

495_connection._streamLifetimeHandler = new LifetimeHandlerInterceptor(_connection._streamLifetimeHandler, this); 498httpConnection.Initialize(_connection); 546if (_connection == null) 555var connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(application)); 608_ => throw new NotImplementedException($"{nameof(_connection.ProcessRequestsAsync)} should invoked instead - hence transport connection manager does not have the connection registered."), 1389((IRequestProcessor)_connection)?.Tick(timestamp);

23_connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication));

182var originalHandler = _connection._streamLifetimeHandler; 193_connection._streamLifetimeHandler = streamLifetimeHandler.Object; 249Assert.Equal(1, _connection.StreamPool.Count); 250Assert.True(_connection.StreamPool.TryPeek(out var pooledStream)); 621var originalHandler = _connection._streamLifetimeHandler; 635_connection._streamLifetimeHandler = streamLifetimeHandler.Object; 686Assert.Equal(1, _connection.StreamPool.Count); 687Assert.True(_connection.StreamPool.TryPeek(out var pooledStream));