2 writes to MultiplexedConnectionContext
InMemory.FunctionalTests (2)
Http3\Http3ConnectionTests.cs (1)
749Http3Api.MultiplexedConnectionContext = new ThrowingMultiplexedConnectionContext(Http3Api, skipCount: 2, requestTcs, abortTcs);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
227MultiplexedConnectionContext ??= new TestMultiplexedConnectionContext(this)
16 references to MultiplexedConnectionContext
InMemory.FunctionalTests (16)
Http3\Http3ConnectionTests.cs (4)
188Assert.Null(await Http3Api.MultiplexedConnectionContext.AcceptAsync().DefaultTimeout()); 218Http3Api.MultiplexedConnectionContext.Abort(); 326var lifetime = Http3Api.MultiplexedConnectionContext.Features.Get<IConnectionLifetimeNotificationFeature>(); 767var errorCodeFeature = Http3Api.MultiplexedConnectionContext.Features.Get<IProtocolErrorCodeFeature>();
Http3\Http3StreamTests.cs (1)
3288Http3Api.MultiplexedConnectionContext.ConnectionClosed.Register(() => tcs.TrySetResult());
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (11)
95internal Dictionary<string, object> ConnectionTags => MultiplexedConnectionContext.Tags.ToDictionary(t => t.Key, t => t.Value); 110var reader = MultiplexedConnectionContext.ToClientAcceptQueue.Reader; 135MultiplexedConnectionContext.ConnectionClosingCts.Cancel(); 178var currentError = (Http3ErrorCode)MultiplexedConnectionContext.Error; 232var metricsContext = MultiplexedConnectionContext.Features.GetRequiredFeature<IConnectionMetricsContextFeature>().MetricsContext; 235connectionId: MultiplexedConnectionContext.ConnectionId, 238connectionContext: MultiplexedConnectionContext, 239connectionFeatures: MultiplexedConnectionContext.Features, 410MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 435MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 454MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext);