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