1 instantiation of HubConnectionContext
Microsoft.AspNetCore.SignalR.Core (1)
HubConnectionHandler.cs (1)
134var connectionContext = new HubConnectionContext(connection, contextOptions, _loggerFactory)
80 references to HubConnectionContext
Microsoft.AspNetCore.SignalR (1)
GetHttpContextExtensions.cs (1)
30public static HttpContext? GetHttpContext(this HubConnectionContext connection)
Microsoft.AspNetCore.SignalR.Core (79)
DefaultHubLifetimeManager.cs (10)
39var connection = _connections[connectionId]; 72var connection = _connections[connectionId]; 99private Task SendToAllConnections(string methodName, object?[] args, Func<HubConnectionContext, object?, bool>? include, object? state = null, CancellationToken cancellationToken = default) 105foreach (var connection in _connections) 147private static void SendToGroupConnections(string methodName, object?[] args, ConcurrentDictionary<string, HubConnectionContext> connections, Func<HubConnectionContext, object?, bool>? include, object? state, ref List<Task>? tasks, ref SerializedHubMessage? message, CancellationToken cancellationToken) 187var connection = _connections[connectionId]; 292public override Task OnConnectedAsync(HubConnectionContext connection) 299public override Task OnDisconnectedAsync(HubConnectionContext connection) 338var connection = _connections[connectionId];
DefaultUserIdProvider.cs (2)
10/// This provider gets the user ID from the connection's <see cref="HubConnectionContext.User"/> name identifier claim. 15public virtual string? GetUserId(HubConnectionContext connection)
HubConnectionContext.cs (11)
65/// Initializes a new instance of the <see cref="HubConnectionContext"/> class. 80_logger = loggerFactory.CreateLogger(typeof(HubConnectionContext)); 82_closedRegistration = connectionContext.ConnectionClosed.Register(static (state) => ((HubConnectionContext)state!).Abort(), this); 87_closedRequestedRegistration = lifetimeNotification.ConnectionClosedRequested.Register(static (state) => ((HubConnectionContext)state!).AbortAllowReconnect(), this); 276static async ValueTask<FlushResult> WriteAsync(MessageBuffer messageBuffer, HubConnectionContext hubConnectionContext, 323static async ValueTask<FlushResult> WriteAsync(MessageBuffer messageBuffer, HubConnectionContext hubConnectionContext, 621Features.Get<IConnectionHeartbeatFeature>()?.OnHeartbeat(state => ((HubConnectionContext)state).KeepAliveTick(), this); 738Features.Get<IConnectionHeartbeatFeature>()?.OnHeartbeat(state => ((HubConnectionContext)state).CheckClientTimeout(), this); 766var connection = (HubConnectionContext)state!; 781static async Task InnerAbortConnection(HubConnectionContext connection)
HubConnectionContextOptions.cs (1)
7/// Options used to configure <see cref="HubConnectionContext"/>.
HubConnectionHandler.cs (5)
134var connectionContext = new HubConnectionContext(connection, contextOptions, _loggerFactory) 161private async Task RunHubAsync(HubConnectionContext connection) 200private async Task HubOnDisconnectedAsync(HubConnectionContext connection, Exception? exception) 239private async Task SendCloseAsync(HubConnectionContext connection, Exception? exception, bool allowReconnect) 263private async Task DispatchMessagesAsync(HubConnectionContext connection)
HubConnectionStore.cs (13)
10/// Stores <see cref="HubConnectionContext"/>s by ID. 17private readonly ConcurrentDictionary<string, HubConnectionContext> _connections = 18new ConcurrentDictionary<string, HubConnectionContext>(StringComparer.Ordinal); 21/// Get the <see cref="HubConnectionContext"/> by connection ID. 25public HubConnectionContext? this[string connectionId] 29_connections.TryGetValue(connectionId, out var connection); 40/// Add a <see cref="HubConnectionContext"/> to the store. 43public void Add(HubConnectionContext connection) 49/// Removes a <see cref="HubConnectionContext"/> from the store. 52public void Remove(HubConnectionContext connection) 69public readonly struct Enumerator : IEnumerator<HubConnectionContext> 71private readonly IEnumerator<KeyValuePair<string, HubConnectionContext>> _enumerator; 85public HubConnectionContext Current => _enumerator.Current.Value;
HubLifetimeManager.cs (2)
20public abstract Task OnConnectedAsync(HubConnectionContext connection); 28public abstract Task OnDisconnectedAsync(HubConnectionContext connection);
Internal\DefaultHubCallerContext.cs (2)
14private readonly HubConnectionContext _connection; 16public DefaultHubCallerContext(HubConnectionContext connection)
Internal\DefaultHubDispatcher.cs (18)
83public override async Task OnConnectedAsync(HubConnectionContext connection) 119public override async Task OnDisconnectedAsync(HubConnectionContext connection, Exception? exception) 154public override Task DispatchMessageAsync(HubConnectionContext connection, HubMessage hubMessage) 245private Task ProcessInvocationBindingFailure(HubConnectionContext connection, InvocationBindingFailureMessage bindingFailureMessage) 254private Task ProcessStreamBindingFailure(HubConnectionContext connection, StreamBindingFailureMessage bindingFailureMessage) 270private Task ProcessStreamItem(HubConnectionContext connection, StreamItemMessage message) 282private Task ProcessInvocation(HubConnectionContext connection, 318private async Task<bool> Invoke(HubMethodDescriptor descriptor, HubConnectionContext connection, 391HubConnectionContext connection, 492private static ValueTask CleanupInvocation(HubConnectionContext connection, HubMethodInvocationMessage hubMessage, IHubActivator<THub>? hubActivator, 511private async Task StreamAsync(string invocationId, HubConnectionContext connection, object?[] arguments, AsyncServiceScope scope, 606private ValueTask<object?> ExecuteHubMethod(ObjectMethodExecutor methodExecutor, THub hub, object?[] arguments, HubConnectionContext connection, IServiceProvider serviceProvider) 648private static async Task SendInvocationError(string? invocationId, HubConnectionContext connection, string errorMessage) 658private void InitializeHub(THub hub, HubConnectionContext connection, bool invokeAllowed = true) 665private static Task<bool> IsHubMethodAuthorized(IServiceProvider provider, HubConnectionContext hubConnectionContext, HubMethodDescriptor descriptor, object?[] hubMethodArguments, Hub hub) 691HubMethodInvocationMessage hubMethodInvocationMessage, HubConnectionContext connection) 719HubConnectionContext connection, AsyncServiceScope scope, ref object?[] arguments, out CancellationTokenSource? cts) 832private static Activity? StartActivity(string operationName, ActivityKind kind, Activity? linkedActivity, IServiceProvider serviceProvider, string methodName, IDictionary<string, string>? headers, ILogger logger, HubConnectionContext? connection = null)
Internal\HubConnectionBinder.cs (2)
11private readonly HubConnectionContext _connection; 14public HubConnectionBinder(HubDispatcher<THub> dispatcher, HubLifetimeManager<THub> lifetimeManager, HubConnectionContext connection)
Internal\HubDispatcher.cs (3)
11public abstract Task OnConnectedAsync(HubConnectionContext connection); 12public abstract Task OnDisconnectedAsync(HubConnectionContext connection, Exception? exception); 13public abstract Task DispatchMessageAsync(HubConnectionContext connection, HubMessage hubMessage);
Internal\HubGroupList.cs (9)
9internal sealed class HubGroupList : IReadOnlyCollection<ConcurrentDictionary<string, HubConnectionContext>> 16public ConcurrentDictionary<string, HubConnectionContext>? this[string groupName] 25public void Add(HubConnectionContext connection, string groupName) 34if (connections.TryRemove(connectionId, out var _) && connections.IsEmpty) 47public IEnumerator<ConcurrentDictionary<string, HubConnectionContext>> GetEnumerator() 57private void CreateOrUpdateGroupWithConnection(string groupName, HubConnectionContext connection) 68HubConnectionContext connection, GroupConnectionList group) 75internal sealed class GroupConnectionList : ConcurrentDictionary<string, HubConnectionContext> 79if (obj is ConcurrentDictionary<string, HubConnectionContext> list)
IUserIdProvider.cs (1)
17string? GetUserId(HubConnectionContext connection);