ConnectionContext

Tcp\TcpConnection.cs (1)

18public class TcpConnection : ConnectionContext, IConnectionInherentKeepAliveFeature

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

1095internal class TestStreamContext : ConnectionContext, IStreamDirectionFeature, IStreamIdFeature, IProtocolErrorCodeFeature, IPersistentStateFeature, IStreamAbortFeature, IDisposable, IStreamClosedFeature

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

14internal abstract partial class TransportConnection : ConnectionContext

DefaultConnectionContext.cs (1)

19public class DefaultConnectionContext : ConnectionContext,

Internal\HttpConnectionContext.cs (1)

22internal sealed partial class HttpConnectionContext : ConnectionContext,

HttpConnection.cs (1)

28public partial class HttpConnection : ConnectionContext, IConnectionInherentKeepAliveFeature

HttpsConfigurationService.cs (1)

189private sealed class ConnectionContextAdapter : ConnectionContext

Internal\WebTransport\WebTransportStream.cs (1)

16internal sealed class WebTransportStream : ConnectionContext, IStreamDirectionFeature, IStreamIdFeature, IConnectionItemsFeature

Middleware\LoggingMultiplexedConnectionMiddleware.cs (1)

86private sealed class LoggingConnectionContext : ConnectionContext

SniOptionsSelectorTests.cs (1)

937private class MockConnectionContext : ConnectionContext

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

1095internal class TestStreamContext : ConnectionContext, IStreamDirectionFeature, IStreamIdFeature, IProtocolErrorCodeFeature, IPersistentStateFeature, IStreamAbortFeature, IDisposable, IStreamClosedFeature

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

14internal abstract partial class TransportConnection : ConnectionContext

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

14internal abstract partial class TransportConnection : ConnectionContext

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

14internal abstract partial class TransportConnection : ConnectionContext

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

14internal abstract partial class TransportConnection : ConnectionContext

HubConnectionTests.Reconnect.cs (1)

1165private class DisposeInterceptingConnectionContextDecorator : ConnectionContext

TestConnection.cs (1)

22internal class TestConnection : ConnectionContext, IConnectionInherentKeepAliveFeature

Shared\TestConnectionContext.cs (1)

10public class TestConnectionContext : ConnectionContext

Internal\MessageBufferTests.cs (1)

555internal sealed class TestConnectionContext : ConnectionContext

Authentication\Connection\ConnectionTypeMiddleware.cs (1)

24public async Task OnConnectionAsync(ConnectionContext context)

Tcp\TcpConnection.cs (1)

59public async ValueTask<ConnectionContext> StartAsync()

Tcp\TcpHubConnectionBuilderExtensions.cs (1)

48public ValueTask<ConnectionContext> ConnectAsync(EndPoint endPoint, CancellationToken cancellationToken = default)

src\Shared\Http2cat\Http2CatHostedService.cs (1)

73await using var context = await _connectionFactory.ConnectAsync(endpoint);

src\Shared\Http2cat\Http2Utilities.cs (1)

135public Http2Utilities(ConnectionContext clientConnectionContext, ILogger logger, CancellationToken stopToken)

src\Shared\Http2cat\Http2CatHostedService.cs (1)

73await using var context = await _connectionFactory.ConnectAsync(endpoint);

src\Shared\Http2cat\Http2Utilities.cs (1)

135public Http2Utilities(ConnectionContext clientConnectionContext, ILogger logger, CancellationToken stopToken)

src\Shared\Http2cat\Http2CatHostedService.cs (1)

73await using var context = await _connectionFactory.ConnectAsync(endpoint);

src\Shared\Http2cat\Http2Utilities.cs (1)

135public Http2Utilities(ConnectionContext clientConnectionContext, ILogger logger, CancellationToken stopToken)

src\Shared\Http2cat\Http2CatHostedService.cs (1)

73await using var context = await _connectionFactory.ConnectAsync(endpoint);

src\Shared\Http2cat\Http2Utilities.cs (1)

135public Http2Utilities(ConnectionContext clientConnectionContext, ILogger logger, CancellationToken stopToken)

src\Shared\Http2cat\Http2CatHostedService.cs (1)

73await using var context = await _connectionFactory.ConnectAsync(endpoint);

src\Shared\Http2cat\Http2Utilities.cs (1)

135public Http2Utilities(ConnectionContext clientConnectionContext, ILogger logger, CancellationToken stopToken)

src\Shared\Http2cat\Http2CatHostedService.cs (1)

73await using var context = await _connectionFactory.ConnectAsync(endpoint);

src\Shared\Http2cat\Http2Utilities.cs (1)

135public Http2Utilities(ConnectionContext clientConnectionContext, ILogger logger, CancellationToken stopToken)

ConnectionLimitTests.cs (1)

240var middleware = new ConnectionLimitMiddleware<ConnectionContext>(c => next(c), concurrentConnectionCounter, serviceContext.Log, metrics: serviceContext.Metrics);

ConnectionMiddlewareTests.cs (2)

340public async Task OnConnectionAsync(ConnectionContext context) 372public async Task OnConnectionAsync(ConnectionContext context)

EventSourceTests.cs (1)

376return new ConnectionLimitMiddleware<ConnectionContext>(c => next(c), connectionLimit: 0, serviceContext.Log, metrics: null).OnConnectionAsync;

Http2\Http2TestBase.cs (2)

124protected readonly Mock<ConnectionContext> _mockConnectionContext = new Mock<ConnectionContext>();

Http3\Http3ConnectionTests.cs (11)

433var streamContext1 = await MakeRequestAsync(0, headers, sendData: true, waitForServerDispose: true); 434var streamContext2 = await MakeRequestAsync(1, headers, sendData: true, waitForServerDispose: true); 460var streamContext1 = await MakeRequestAsync(0, headers, sendData: true, waitForServerDispose: true); 464var streamContext2 = await MakeRequestAsync(1, headers, sendData: true, waitForServerDispose: true); 500var streamContext1 = await MakeRequestAsync(0, requestHeaders1, sendData: true, waitForServerDispose: true); 507var streamContext2 = await MakeRequestAsync(1, requestHeaders2, sendData: true, waitForServerDispose: true); 534ConnectionContext first = null; 535ConnectionContext last = null; 540var streamContext = await MakeRequestAsync(i, headers, sendData: true, waitForServerDispose: true); 791public override async ValueTask<ConnectionContext> AcceptAsync(CancellationToken cancellationToken = default) 811private async Task<ConnectionContext> MakeRequestAsync(int index, KeyValuePair<string, string>[] headers, bool sendData, bool waitForServerDispose)

KestrelMetricsTests.cs (1)

321ConnectionContext currentConnectionContext = null;

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

991public readonly Channel<ConnectionContext> ToServerAcceptQueue = Channel.CreateUnbounded<ConnectionContext>(new UnboundedChannelOptions 1055public override async ValueTask<ConnectionContext> AcceptAsync(CancellationToken cancellationToken = default) 1061while (ToServerAcceptQueue.Reader.TryRead(out var connection)) 1075public override ValueTask<ConnectionContext> ConnectAsync(IFeatureCollection features = null, CancellationToken cancellationToken = default) 1082return new ValueTask<ConnectionContext>(stream.StreamContext);

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

21public Task OnConnectionAsync(ConnectionContext context)

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

49ConnectionContext connectionContext, 253public override ValueTask<ConnectionContext> AcceptAsync(CancellationToken cancellationToken = default) 258public override ValueTask<ConnectionContext> ConnectAsync(IFeatureCollection features = null, CancellationToken cancellationToken = default)

TestTransport\InMemoryTransportFactory.cs (5)

15private readonly Channel<ConnectionContext> _acceptQueue = Channel.CreateUnbounded<ConnectionContext>(); 19public void AddConnection(ConnectionContext connection) 24public async ValueTask<ConnectionContext> AcceptAsync(CancellationToken cancellationToken = default) 28while (_acceptQueue.Reader.TryRead(out var item))

ConnectionBuilderExtensions.cs (6)

32/// If you aren't calling the next function, use <see cref="Run(IConnectionBuilder, Func{ConnectionContext, Task})"/> instead. 34/// Prefer using <see cref="Use(IConnectionBuilder, Func{ConnectionContext, ConnectionDelegate, Task})"/> for better performance as shown below: 46public static IConnectionBuilder Use(this IConnectionBuilder connectionBuilder, Func<ConnectionContext, Func<Task>, Task> middleware) 60/// If you aren't calling the next function, use <see cref="Run(IConnectionBuilder, Func{ConnectionContext, Task})"/> instead. 65public static IConnectionBuilder Use(this IConnectionBuilder connectionBuilder, Func<ConnectionContext, ConnectionDelegate, Task> middleware) 76public static IConnectionBuilder Run(this IConnectionBuilder connectionBuilder, Func<ConnectionContext, Task> middleware)

ConnectionDelegate.cs (2)

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

ConnectionHandler.cs (2)

16/// <param name="connection">The new <see cref="ConnectionContext"/></param> 18public abstract Task OnConnectedAsync(ConnectionContext connection);

DefaultConnectionContext.cs (1)

17/// The default implementation for the <see cref="ConnectionContext"/>.

IConnectionFactory.cs (2)

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

IConnectionListener.cs (2)

25/// <returns>A <see cref="ValueTask{ConnectionContext}"/> that completes when a connection is accepted, yielding the <see cref="ConnectionContext" /> representing the connection.</returns> 26ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default);

MultiplexedConnectionContext.cs (2)

21public abstract ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default); 29public abstract ValueTask<ConnectionContext> ConnectAsync(IFeatureCollection? features = null, CancellationToken cancellationToken = default);

Features\IHttpContextFeature.cs (1)

9/// Feature set on the <see cref="ConnectionContext"/> that provides access to the underlying <see cref="Http.HttpContext"/>

Features\IHttpTransportFeature.cs (1)

9/// Feature set on the <see cref="ConnectionContext"/> that exposes the <see cref="HttpTransportType"/>

HttpConnectionContextExtensions.cs (2)

17/// <param name="connection">The <see cref="ConnectionContext"/> representing the connection.</param> 23public static HttpContext? GetHttpContext(this ConnectionContext connection)

HttpConnectionFactory.cs (2)

42/// A <see cref="ValueTask{TResult}" /> that represents the asynchronous connect, yielding the <see cref="ConnectionContext" /> for the new connection when completed. 44public async ValueTask<ConnectionContext> ConnectAsync(EndPoint endPoint, CancellationToken cancellationToken = default)

HttpConnectionDispatcherTests.cs (11)

MapConnectionHandlerTests.cs (4)

432public override async Task OnConnectedAsync(ConnectionContext connection) 452public override Task OnConnectedAsync(ConnectionContext connection) 460public override Task OnConnectedAsync(ConnectionContext connection) 474public override Task OnConnectedAsync(ConnectionContext connection)

IWebTransportSession.cs (2)

33ValueTask<ConnectionContext?> AcceptStreamAsync(CancellationToken cancellationToken = default); 40ValueTask<ConnectionContext?> OpenUnidirectionalStreamAsync(CancellationToken cancellationToken = default);

src\Shared\Http2cat\Http2CatHostedService.cs (1)

73await using var context = await _connectionFactory.ConnectAsync(endpoint);

src\Shared\Http2cat\Http2Utilities.cs (1)

135public Http2Utilities(ConnectionContext clientConnectionContext, ILogger logger, CancellationToken stopToken)

HttpsConnectionAdapterOptions.cs (3)

50/// If SNI is not available then the name parameter will be null. The <see cref="ConnectionContext"/> will be null for HTTP/3 connections. 56public Func<ConnectionContext?, string?, X509Certificate2?>? ServerCertificateSelector { get; set; } 97public Action<ConnectionContext, SslServerAuthenticationOptions>? OnAuthenticate { get; set; }

Internal\Http3\Http3Connection.cs (4)

363var streamContext = await _multiplexedContext.AcceptAsync(_acceptStreamsCts.Token); 581private async Task CreateHttp3Stream<TContext>(ConnectionContext streamContext, IHttpApplication<TContext> application, long streamId) where TContext : notnull 659internal Http3StreamContext CreateHttpStreamContext(ConnectionContext streamContext) 739var streamContext = await _multiplexedContext.ConnectAsync(features);

Internal\Http3\Http3FrameWriter.cs (2)

35private readonly ConnectionContext _connectionContext; 59public Http3FrameWriter(ConnectionContext connectionContext, ITimeoutControl timeoutControl, MinDataRate? minResponseDataRate, MemoryPool<byte> memoryPool, KestrelTrace log, IStreamIdFeature streamIdFeature, Http3PeerSettings clientPeerSettings, IHttp3Stream http3Stream)

Internal\Http3\Http3StreamContext.cs (2)

25ConnectionContext streamContext, 36public ConnectionContext StreamContext { get; }

Internal\Infrastructure\ConnectionMetricsContext.cs (1)

10public required BaseConnectionContext ConnectionContext { get; init; }

Internal\Infrastructure\TransportManager.cs (2)

196private sealed class GenericConnectionListener : IConnectionListener<ConnectionContext> 207public ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default)

Internal\KestrelServerImpl.cs (1)

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

Internal\SniOptionsSelector.cs (3)

25private readonly Func<ConnectionContext, string?, X509Certificate2?>? _fallbackServerCertificateSelector; 26private readonly Action<ConnectionContext, SslServerAuthenticationOptions>? _onAuthenticateCallback; 116public (SslServerAuthenticationOptions, ClientCertificateMode) GetOptions(ConnectionContext connection, string serverName)

Internal\TlsConnectionFeature.cs (2)

18private readonly ConnectionContext _context; 22public TlsConnectionFeature(SslStream sslStream, ConnectionContext context)

Internal\WebTransport\WebTransportSession.cs (3)

122public async ValueTask<ConnectionContext?> OpenUnidirectionalStreamAsync(CancellationToken cancellationToken) 131var connectionContext = await _connection._multiplexedContext.ConnectAsync(features, cancellationToken); 166public async ValueTask<ConnectionContext?> AcceptStreamAsync(CancellationToken cancellationToken)

Middleware\HttpConnectionMiddleware.cs (1)

28public Task OnConnectionAsync(ConnectionContext connectionContext)

Middleware\HttpsConnectionMiddleware.cs (4)

41private readonly Func<ConnectionContext, string?, X509Certificate2?>? _serverCertificateSelector; 134public async Task OnConnectionAsync(ConnectionContext context) 316private Task DoOptionsBasedHandshakeAsync(ConnectionContext context, SslStream sslStream, Core.Internal.TlsConnectionFeature feature, CancellationToken cancellationToken) 441var (middleware, context, feature, metricsContext) = (ValueTuple<HttpsConnectionMiddleware, ConnectionContext, Core.Internal.TlsConnectionFeature, ConnectionMetricsContext>)state!;

Middleware\LoggingConnectionMiddleware.cs (1)

20public async Task OnConnectionAsync(ConnectionContext context)

Middleware\LoggingMultiplexedConnectionMiddleware.cs (6)

57public override async ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default) 59var context = await _inner.AcceptAsync(cancellationToken); 67public override async ValueTask<ConnectionContext> ConnectAsync(IFeatureCollection? features = null, CancellationToken cancellationToken = default) 69var context = await _inner.ConnectAsync(features, cancellationToken); 88private readonly ConnectionContext _inner; 92public LoggingConnectionContext(ConnectionContext inner, ILogger logger)

TlsHandshakeCallbackContext.cs (1)

42public ConnectionContext Connection { get; internal set; } = default!;

ConnectionContextTests.cs (1)

15var mockConnectionContext = new Mock<ConnectionContext> { CallBase = true };

ConnectionDispatcherTests.cs (6)

62var dispatcher = new ConnectionDispatcher<ConnectionContext>(serviceContext, _ => Task.CompletedTask, new TransportConnectionManager(serviceContext.ConnectionManager)); 118private static KestrelConnection<ConnectionContext> CreateKestrelConnection(TestServiceContext serviceContext, DefaultConnectionContext connection, TransportConnectionManager transportConnectionManager, Func<ConnectionContext, Task> connectionDelegate = null) 122return new KestrelConnection<ConnectionContext>( 126private class ThrowingListener : IConnectionListener<ConnectionContext> 130public ValueTask<ConnectionContext> AcceptAsync(CancellationToken cancellationToken = default)

Http1\Http1ConnectionTestsBase.cs (3)

41var connectionContext = Mock.Of<ConnectionContext>(); 56connectionContext: Mock.Of<ConnectionContext>(),

Http1\Http1HttpProtocolFeatureCollectionTests.cs (2)

29var connectionContext = Mock.Of<ConnectionContext>();

Http1\Http1OutputProducerTests.cs (4)

120var mockConnectionContext = new Mock<ConnectionContext>(); 225ConnectionContext connectionContext = null, 229connectionContext = connectionContext ?? Mock.Of<ConnectionContext>(); 254public TestHttpOutputProducer(Pipe pipe, string connectionId, ConnectionContext connectionContext, MemoryPool<byte> memoryPool, KestrelTrace log, ITimeoutControl timeoutControl, IHttpMinResponseDataRateFeature minResponseDataRateFeature, ConnectionMetricsContext metricsContext, IHttpOutputAborter outputAborter)

HttpConnectionManagerTests.cs (1)

49var httpConnection = new KestrelConnection<ConnectionContext>(0, serviceContext, transportConnectionManager, _ => Task.CompletedTask, mock.Object, trace, TestContextFactory.CreateMetricsContext(mock.Object));

HttpConnectionTests.cs (1)

22var mockConnectionContext = new Mock<ConnectionContext>();

HttpResponseHeadersTests.cs (2)

29var connectionContext = Mock.Of<ConnectionContext>();

KestrelServerTests.cs (8)

559.Returns(new ValueTask<ConnectionContext>((ConnectionContext)null)); 616.Returns(new ValueTask<ConnectionContext>((ConnectionContext)null)); 675.Returns(new ValueTask<ConnectionContext>((ConnectionContext)null)); 812.Returns(new ValueTask<ConnectionContext>(result: null)); 950.Returns(new ValueTask<ConnectionContext>(result: null));

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

21public Task OnConnectionAsync(ConnectionContext context)

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

49ConnectionContext connectionContext, 253public override ValueTask<ConnectionContext> AcceptAsync(CancellationToken cancellationToken = default) 258public override ValueTask<ConnectionContext> ConnectAsync(IFeatureCollection features = null, CancellationToken cancellationToken = default)

StartLineTests.cs (1)

531connectionContext: Mock.Of<ConnectionContext>(),

TestHelpers\TestInput.cs (2)

33var connectionContext = Mock.Of<ConnectionContext>();

InMemoryTransportBenchmark.cs (5)

135private readonly TaskCompletionSource<ConnectionContext> _tcs = new TaskCompletionSource<ConnectionContext>(TaskCreationOptions.RunContinuationsAsynchronously); 146public ValueTask<ConnectionContext> AcceptAsync(CancellationToken cancellationToken = default) 150return new ValueTask<ConnectionContext>(_connections[_acceptedConnections++]); 152return new ValueTask<ConnectionContext>(_tcs.Task);

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

991public readonly Channel<ConnectionContext> ToServerAcceptQueue = Channel.CreateUnbounded<ConnectionContext>(new UnboundedChannelOptions 1055public override async ValueTask<ConnectionContext> AcceptAsync(CancellationToken cancellationToken = default) 1061while (ToServerAcceptQueue.Reader.TryRead(out var connection)) 1075public override ValueTask<ConnectionContext> ConnectAsync(IFeatureCollection features = null, CancellationToken cancellationToken = default) 1082return new ValueTask<ConnectionContext>(stream.StreamContext);

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

49ConnectionContext connectionContext, 253public override ValueTask<ConnectionContext> AcceptAsync(CancellationToken cancellationToken = default) 258public override ValueTask<ConnectionContext> ConnectAsync(IFeatureCollection features = null, CancellationToken cancellationToken = default)

Internal\NamedPipeConnectionListener.cs (4)

26private readonly Channel<ConnectionContext> _acceptedQueue; 52_acceptedQueue = Channel.CreateBounded<ConnectionContext>(new BoundedChannelOptions(capacity: 1)); 147public async ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default) 151if (_acceptedQueue.Reader.TryRead(out var connection))

Internal\QuicConnectionContext.cs (2)

93public override async ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default) 210public override async ValueTask<ConnectionContext> ConnectAsync(IFeatureCollection? features = null, CancellationToken cancellationToken = default)

QuicConnectionContextTests.cs (2)

96var serverStream = await acceptStreamTask.DefaultTimeout(); 610var serverStream = await requestState.ServerConnection.AcceptAsync().DefaultTimeout();

QuicTestHelpers.cs (1)

152var serverStream = await serverConnection.AcceptAsync().DefaultTimeout();

Client\SocketConnectionFactory.cs (1)

47public async ValueTask<ConnectionContext> ConnectAsync(EndPoint endpoint, CancellationToken cancellationToken = default)

SocketConnectionContextFactory.cs (2)

84/// Create a <see cref="ConnectionContext"/> for a socket. 88public ConnectionContext Create(Socket socket)

SocketConnectionListener.cs (1)

59public async ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default)

HubConnection.cs (4)

495var connection = await _connectionFactory.ConnectAsync(_endPoint, cancellationToken).ConfigureAwait(false); 553private static ValueTask CloseAsync(ConnectionContext connection) 2140public ConnectionContext Connection { get; } 2157public ConnectionState(ConnectionContext connection, HubConnection hubConnection)

src\SignalR\common\Shared\MessageBuffer.cs (2)

63public MessageBuffer(ConnectionContext connection, IHubProtocol protocol, long bufferLimit, ILogger logger) 68public MessageBuffer(ConnectionContext connection, IHubProtocol protocol, long bufferLimit, ILogger logger, TimeProvider timeProvider)

HubConnectionTests.cs (1)

73private static Func<EndPoint, ValueTask<ConnectionContext>> GetHttpConnectionFactory(string url, ILoggerFactory loggerFactory, string path, HttpTransportType transportType, TransferFormat transferFormat)

HubProtocolVersionTests.cs (3)

134var connectionContext = await proxyConnectionFactory.ConnectTask.DefaultTimeout(); 235public ValueTask<ConnectionContext> ConnectTask { get; private set; } 242public ValueTask<ConnectionContext> ConnectAsync(EndPoint endPoint, CancellationToken cancellationToken = default)

HubConnectionTests.ConnectionLifecycle.cs (2)

82ValueTask<ConnectionContext> ConnectionFactory(EndPoint endPoint) 114ValueTask<ConnectionContext> ConnectionFactory(EndPoint endPoint)

HubConnectionTests.Reconnect.cs (4)

1138public async ValueTask<ConnectionContext> ConnectAsync(EndPoint endPoint, CancellationToken cancellationToken = default) 1155public async Task DisposeAsync(ConnectionContext connection) 1167private readonly ConnectionContext _inner; 1170public DisposeInterceptingConnectionContextDecorator(ConnectionContext inner, ReconnectingConnectionFactory reconnectingConnectionFactory)

TestConnection.cs (1)

66public async ValueTask<ConnectionContext> StartAsync()

HubConnectionContext.cs (3)

28private readonly ConnectionContext _connectionContext; 67/// <param name="connectionContext">The underlying <see cref="ConnectionContext"/>.</param> 70public HubConnectionContext(ConnectionContext connectionContext, HubConnectionContextOptions contextOptions, ILoggerFactory loggerFactory)

HubConnectionHandler.cs (1)

108public override async Task OnConnectedAsync(ConnectionContext connection)

src\SignalR\common\Shared\MessageBuffer.cs (2)

63public MessageBuffer(ConnectionContext connection, IHubProtocol protocol, long bufferLimit, ILogger logger) 68public MessageBuffer(ConnectionContext connection, IHubProtocol protocol, long bufferLimit, ILogger logger, TimeProvider timeProvider)

DefaultHubDispatcherBenchmark.cs (1)

87public NoErrorHubConnectionContext(ConnectionContext connectionContext, HubConnectionContextOptions contextOptions, ILoggerFactory loggerFactory)

HubConnectionReceiveBenchmark.cs (1)

83return new ValueTask<ConnectionContext>(connection);

HubConnectionSendBenchmark.cs (1)

63return new ValueTask<ConnectionContext>(connection);

HubConnectionStartBenchmark.cs (1)

49return new ValueTask<ConnectionContext>(connection);

src\SignalR\common\testassets\Tests.Utils\HubConnectionContextUtils.cs (3)

17public static HubConnectionContext Create(ConnectionContext connection, IHubProtocol protocol = null, string userIdentifier = null) 31public static MockHubConnectionContext CreateMock(ConnectionContext connection) 44public MockHubConnectionContext(ConnectionContext connectionContext, HubConnectionContextOptions contextOptions, ILoggerFactory loggerFactory)

AuthConnectionHandler.cs (1)

14public override async Task OnConnectedAsync(ConnectionContext connection)

EchoConnectionHandler.cs (1)

12public override async Task OnConnectedAsync(ConnectionContext connection)

HttpHeaderConnectionHandler.cs (1)

16public override async Task OnConnectedAsync(ConnectionContext connection)

Internal\MessageBufferTests.cs (1)

599public static void UpdateConnectionPair(ref DuplexPipePair duplexPipePair, ConnectionContext connection, PipeOptions pipeOptions = null)

WriteThenCloseConnectionHandler.cs (1)

12public override async Task OnConnectedAsync(ConnectionContext connection)

DelegateConnectionFactory.cs (3)

11private readonly Func<EndPoint, ValueTask<ConnectionContext>> _connectDelegate; 14public DelegateConnectionFactory(Func<EndPoint, ValueTask<ConnectionContext>> connectDelegate) 19public ValueTask<ConnectionContext> ConnectAsync(EndPoint endPoint, CancellationToken cancellationToken)

HubConnectionContextUtils.cs (3)

17public static HubConnectionContext Create(ConnectionContext connection, IHubProtocol protocol = null, string userIdentifier = null) 31public static MockHubConnectionContext CreateMock(ConnectionContext connection) 44public MockHubConnectionContext(ConnectionContext connectionContext, HubConnectionContextOptions contextOptions, ILoggerFactory loggerFactory)

EchoConnectionHandler.cs (1)

11public override async Task OnConnectedAsync(ConnectionContext connection)

ConnectionHandlers\MessagesConnectionHandler.cs (2)

15public override async Task OnConnectedAsync(ConnectionContext connection) 66foreach (var c in Connections)

ConnectionList.cs (9)

10internal class ConnectionList : IReadOnlyCollection<ConnectionContext> 12private readonly ConcurrentDictionary<string, ConnectionContext> _connections = new ConcurrentDictionary<string, ConnectionContext>(StringComparer.Ordinal); 14public ConnectionContext this[string connectionId] 18if (_connections.TryGetValue(connectionId, out var connection)) 28public void Add(ConnectionContext connection) 33public void Remove(ConnectionContext connection) 35_connections.TryRemove(connection.ConnectionId, out var dummy); 38public IEnumerator<ConnectionContext> GetEnumerator()

ConnectionList.cs (9)

10internal class ConnectionList : IReadOnlyCollection<ConnectionContext> 12private readonly ConcurrentDictionary<string, ConnectionContext> _connections = 13new ConcurrentDictionary<string, ConnectionContext>(StringComparer.Ordinal); 15public ConnectionContext this[string connectionId] 19if (_connections.TryGetValue(connectionId, out var connection)) 29public void Add(ConnectionContext connection) 34public void Remove(ConnectionContext connection) 36_connections.TryRemove(connection.ConnectionId, out var dummy); 39public IEnumerator<ConnectionContext> GetEnumerator()

PersistentConnectionLifeTimeManager.cs (5)

20public void OnConnectedAsync(ConnectionContext connection) 36public void OnDisconnectedAsync(ConnectionContext connection) 43foreach (var connection in _connectionList) 69public void AddGroupAsync(ConnectionContext connection, string groupName) 78public void RemoveGroupAsync(ConnectionContext connection, string groupName)

SocialWeatherConnectionHandler.cs (2)

23public override async Task OnConnectedAsync(ConnectionContext connection) 30public async Task ProcessRequests(ConnectionContext connection)

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

21public Task OnConnectionAsync(ConnectionContext context)

src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (1)

46async Task EchoServer(ConnectionContext connection)

Program.cs (4)

71ConnectionContext? stream = null; 93static async Task handleUnidirectionalStream(IWebTransportSession session, ConnectionContext stream) 113static async Task handleBidirectionalStream(IWebTransportSession session, ConnectionContext stream) 145var stream = await session.OpenUnidirectionalStreamAsync();

Program.cs (1)

34var stream = await session.AcceptStreamAsync(CancellationToken.None);