MultiplexedConnectionContext

2 writes to MultiplexedConnectionContext

InMemory.FunctionalTests (2)

Http3\Http3ConnectionTests.cs (1)

720Http3Api.MultiplexedConnectionContext = new ThrowingMultiplexedConnectionContext(Http3Api, skipCount: 2, requestTcs, abortTcs);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

228MultiplexedConnectionContext ??= new TestMultiplexedConnectionContext(this)

15 references to MultiplexedConnectionContext

InMemory.FunctionalTests (15)

Http3\Http3ConnectionTests.cs (4)

188Assert.Null(await Http3Api.MultiplexedConnectionContext.AcceptAsync().DefaultTimeout()); 218Http3Api.MultiplexedConnectionContext.Abort(); 326var lifetime = Http3Api.MultiplexedConnectionContext.Features.Get<IConnectionLifetimeNotificationFeature>(); 738var errorCodeFeature = Http3Api.MultiplexedConnectionContext.Features.Get<IProtocolErrorCodeFeature>();

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (11)

96internal Dictionary<string, object> ConnectionTags => MultiplexedConnectionContext.Tags.ToDictionary(t => t.Key, t => t.Value); 111var reader = MultiplexedConnectionContext.ToClientAcceptQueue.Reader; 136MultiplexedConnectionContext.ConnectionClosingCts.Cancel(); 179var currentError = (Http3ErrorCode)MultiplexedConnectionContext.Error; 233var metricsContext = MultiplexedConnectionContext.Features.GetRequiredFeature<IConnectionMetricsContextFeature>().MetricsContext; 236connectionId: MultiplexedConnectionContext.ConnectionId, 239connectionContext: MultiplexedConnectionContext, 240connectionFeatures: MultiplexedConnectionContext.Features, 411MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 435MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 453MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext);