MultiplexedConnectionContext

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

988internal class TestMultiplexedConnectionContext : MultiplexedConnectionContext, IConnectionLifetimeNotificationFeature, IConnectionLifetimeFeature, IConnectionHeartbeatFeature, IProtocolErrorCodeFeature, IConnectionMetricsContextFeature, IConnectionMetricsTagsFeature

src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)

239private class TestMultiplexedConnectionContext : MultiplexedConnectionContext

Middleware\LoggingMultiplexedConnectionMiddleware.cs (1)

32private sealed class LoggingMultiplexedConnectionContext : MultiplexedConnectionContext

src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)

239private class TestMultiplexedConnectionContext : MultiplexedConnectionContext

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

988internal class TestMultiplexedConnectionContext : MultiplexedConnectionContext, IConnectionLifetimeNotificationFeature, IConnectionLifetimeFeature, IConnectionHeartbeatFeature, IProtocolErrorCodeFeature, IConnectionMetricsContextFeature, IConnectionMetricsTagsFeature

src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)

239private class TestMultiplexedConnectionContext : MultiplexedConnectionContext

src\Servers\Kestrel\shared\TransportMultiplexedConnection.cs (1)

11internal abstract partial class TransportMultiplexedConnection : MultiplexedConnectionContext

src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)

77MultiplexedConnectionContext connectionContext = null,

TestTransport\MockMultiplexedConnectionListenerFactory.cs (2)

33public ValueTask<MultiplexedConnectionContext> AcceptAsync(IFeatureCollection features = null, CancellationToken cancellationToken = default) 35return ValueTask.FromResult<MultiplexedConnectionContext>(null);

Http3\Http3RequestTests.cs (2)

1853var connectionStartedTcs = new TaskCompletionSource<MultiplexedConnectionContext>(TaskCreationOptions.RunContinuationsAsynchronously); 1893var connection = await connectionStartedTcs.Task.DefaultTimeout();

IMulitplexedConnectionListener.cs (2)

34/// <returns>A <see cref="ValueTask{MultiplexedConnectionContext}"/> that completes when a connection is accepted, yielding the <see cref="MultiplexedConnectionContext" /> representing the connection.</returns> 35ValueTask<MultiplexedConnectionContext?> AcceptAsync(IFeatureCollection? features = null, CancellationToken cancellationToken = default);

IMultiplexedConnectionFactory.cs (2)

23/// A <see cref="ValueTask{TResult}" /> that represents the asynchronous connect, yielding the <see cref="MultiplexedConnectionContext" /> for the new connection when completed. 25ValueTask<MultiplexedConnectionContext> ConnectAsync(EndPoint endpoint, IFeatureCollection? features = null, CancellationToken cancellationToken = default);

MultiplexedConnectionDelegate.cs (2)

11/// <param name="connection">A <see cref="MultiplexedConnectionContext" /> representing the connection.</param> 13public delegate Task MultiplexedConnectionDelegate(MultiplexedConnectionContext connection);

Internal\Http3\Http3Connection.cs (2)

28internal readonly MultiplexedConnectionContext _multiplexedContext; 56_multiplexedContext = (MultiplexedConnectionContext)context.ConnectionContext;

Internal\HttpMultiplexedConnectionContext.cs (1)

18MultiplexedConnectionContext connectionContext,

Internal\Infrastructure\KestrelMetrics.cs (1)

343var transport = metricsContext.ConnectionContext is not MultiplexedConnectionContext ? "tcp" : "udp";

Internal\Infrastructure\TransportManager.cs (2)

217private sealed class GenericMultiplexedConnectionListener : IConnectionListener<MultiplexedConnectionContext> 228public ValueTask<MultiplexedConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default)

Internal\KestrelServerImpl.cs (1)

449return new ConnectionLimitMiddleware<MultiplexedConnectionContext>(c => innerDelegate(c), connectionLimit.Value, trace, metrics).OnConnectionAsync;

Middleware\HttpMultiplexedConnectionMiddleware.cs (1)

28public Task OnConnectionAsync(MultiplexedConnectionContext connectionContext)

Middleware\LoggingMultiplexedConnectionMiddleware.cs (4)

23public Task OnConnectionAsync(MultiplexedConnectionContext context) 29/// Wrap the initial <see cref="MultiplexedConnectionContext"/>. 34private readonly MultiplexedConnectionContext _inner; 37public LoggingMultiplexedConnectionContext(MultiplexedConnectionContext inner, ILogger logger)

src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)

77MultiplexedConnectionContext connectionContext = null,

src\Servers\Kestrel\shared\test\TestContextFactory.cs (1)

77MultiplexedConnectionContext connectionContext = null,

Internal\QuicConnectionListener.cs (1)

146public async ValueTask<MultiplexedConnectionContext?> AcceptAsync(IFeatureCollection? features = null, CancellationToken cancellationToken = default)

QuicConnectionContextTests.cs (17)

QuicConnectionListenerTests.cs (7)

56var serverConnection = await acceptTask.DefaultTimeout(); 77var serverConnection1 = await acceptTask1.DefaultTimeout(); 102var serverConnection2 = await acceptTask2.DefaultTimeout(); 124var serverConnection = await connectionListener.AcceptAndAddFeatureAsync().DefaultTimeout(); 264await using var serverConnection = await acceptTask.DefaultTimeout(); 322await using var serverConnection = await acceptTask.DefaultTimeout(); 363await using var serverConnection = await acceptTask.DefaultTimeout();

QuicStreamContextTests.cs (14)

QuicTestHelpers.cs (3)

100public static async ValueTask<MultiplexedConnectionContext> AcceptAndAddFeatureAsync(this IMultiplexedConnectionListener listener) 102var connection = await listener.AcceptAsync(); 143public static async Task<QuicStreamContext> CreateAndCompleteBidirectionalStreamGracefully(QuicConnection clientConnection, MultiplexedConnectionContext serverConnection, ILogger logger)