2 writes to Context
Microsoft.AspNetCore.Components.Server.Tests (1)
Circuits\ComponentHubTest.cs (1)
132hub.Context = mockContext.Object;
Microsoft.AspNetCore.SignalR.Core (1)
Internal\DefaultHubDispatcher.cs (1)
629hub.Context = connection.HubCallerContext;
83 references to Context
Microsoft.AspNetCore.Components.Server (21)
ComponentHub.cs (21)
74var circuitHost = _circuitHandleRegistry.GetCircuit(Context.Items, CircuitKey); 80return _circuitRegistry.DisconnectAsync(circuitHost, Context.ConnectionId); 85var circuitHost = _circuitHandleRegistry.GetCircuit(Context.Items, CircuitKey); 92Context.Abort(); 108Context.Abort(); 116Context.Abort(); 122var circuitClient = new CircuitClientProxy(Clients.Caller, Context.ConnectionId); 132Context.User, 139_ = circuitHost.InitializeAsync(store, Context.ConnectionAborted); 144_circuitHandleRegistry.SetCircuit(Context.Items, CircuitKey, circuitHost); 149Log.CreatedCircuit(_logger, circuitHost.CircuitId, circuitHost.CircuitId.Secret, Context.ConnectionId); 158Context.Abort(); 178Context.Abort(); 187_ = circuitHost.UpdateRootComponents(operations, store, Context.ConnectionAborted); 204Context.ConnectionId, 205Context.ConnectionAborted); 208_circuitHandleRegistry.SetCircuit(Context.Items, CircuitKey, circuitHost); 209circuitHost.SetCircuitUser(Context.User); 345var handle = _circuitHandleRegistry.GetCircuitHandle(Context.Items, CircuitKey); 353Context.Abort(); 362Context.Abort();
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (16)
Hubs.cs (16)
31await Clients.Client(Context.ConnectionId).SendAsync("Echo", message); 36await Clients.Client(Context.ConnectionId).SendAsync("NoClientHandler"); 41return Context.ConnectionId; 52return Context.UserIdentifier; 57var context = Context.GetHttpContext(); 76return Context.GetHttpContext().Request.Cookies[cookieName]; 81var feature = Context.Features.Get<IHttpConnectionFeature>(); 96return Context.Features.Get<IHttpTransportFeature>().TransportType.ToString(); 101return Context.GetHttpContext()?.Request?.Protocol ?? "unknown"; 106Context.Abort(); 151await Clients.Client(Context.ConnectionId).Echo(message); 156await Clients.Client(Context.ConnectionId).NoClientHandler(); 161return Context.ConnectionId; 185await Clients.Client(Context.ConnectionId).Echo(message); 190await Clients.Client(Context.ConnectionId).NoClientHandler(); 195return Context.ConnectionId;
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (1)
EchoHub.cs (1)
28return Groups.AddToGroupAsync(Context.ConnectionId, groupName);
Microsoft.AspNetCore.SignalR.Tests (23)
HubConnectionHandlerTestUtils\Hubs.cs (23)
20return Groups.RemoveFromGroupAsync(Context.ConnectionId, groupName); 45return Groups.AddToGroupAsync(Context.ConnectionId, groupName); 125return Clients.Client(Context.ConnectionId).SendAsync("Send", new { }); 169return Context.GetHttpContext() != null; 309Context.Items[nameof(UploadDoesWorkOnComplete)] = tcs.Task; 333Context.ConnectionAborted.Register(state => ((TaskCompletionSource)state).SetResult(), tcs); 400var tcs = (TaskCompletionSource)Context.Items["ConnectedTask"]; 410var tcs = (TaskCompletionSource)Context.Items["ConnectedTask"]; 442return Groups.AddToGroupAsync(Context.ConnectionId, groupName); 490var tcs = (TaskCompletionSource)Context.Items["ConnectedTask"]; 528return Groups.AddToGroupAsync(Context.ConnectionId, groupName); 573await Clients.Client(Context.ConnectionId).GetClientResult(clientValue), 696Context.Abort(); 985await Clients.All.SendAsync("Send", $"{Context.ConnectionId} joined"); 1004await Clients.All.Send($"{Context.ConnectionId} joined"); 1240Context.Items[nameof(OnConnectedAsync)] = true; 1242Context.ConnectionAborted.Register(() => 1252Context.Items[nameof(OnDisconnectedAsync)] = true; 1269_state.TokenStateInConnected = Context.ConnectionAborted.IsCancellationRequested; 1271Context.ConnectionAborted.Register(() => 1291_state.TokenStateInDisconnected = Context.ConnectionAborted.IsCancellationRequested; 1337var tcs = (TaskCompletionSource)Context.Items["ConnectedTask"]; 1461string id = Context.GetHttpContext()?.Request.Query["client"] ?? string.Empty;
SignalR.Client.FunctionalTestApp (9)
TestHub.cs (9)
37return Context.ConnectionId; 42return int.Parse(Context.GetHttpContext().Request.Query["numRedirects"], CultureInfo.InvariantCulture); 52return Clients.Client(Context.ConnectionId).SendAsync("Message", message); 57return Clients.Client(Context.ConnectionId).SendAsync("CustomObject", customObject); 73var connectionId = Context.ConnectionId; 112return Context.Features.Get<IHttpTransportFeature>().TransportType.ToString(); 134return Context.GetHttpContext().Request.Headers["Content-Type"]; 139return Context.GetHttpContext().Request.Headers[headerName]; 144var cookies = Context.GetHttpContext().Request.Cookies;
SignalRSamples (13)
Hubs\Chat.cs (4)
12var name = Context.GetHttpContext().Request.Query["name"]; 18var name = Context.GetHttpContext().Request.Query["name"]; 49await Groups.AddToGroupAsync(Context.ConnectionId, groupName); 58await Groups.RemoveFromGroupAsync(Context.ConnectionId, groupName);
Hubs\DynamicChat.cs (4)
12var name = Context.GetHttpContext().Request.Query["name"]; 18var name = Context.GetHttpContext().Request.Query["name"]; 44await Groups.AddToGroupAsync(Context.ConnectionId, groupName); 53await Groups.RemoveFromGroupAsync(Context.ConnectionId, groupName);
Hubs\HubTChat.cs (4)
12var name = Context.GetHttpContext().Request.Query["name"]; 18var name = Context.GetHttpContext().Request.Query["name"]; 44await Groups.AddToGroupAsync(Context.ConnectionId, groupName); 53await Groups.RemoveFromGroupAsync(Context.ConnectionId, groupName);
Hubs\Streaming.cs (1)
27return observable.AsChannelReader(Context.ConnectionAborted);