2 writes to Context
Microsoft.AspNetCore.Components.Server.Tests (1)
Circuits\ComponentHubTest.cs (1)
328hub.Context = mockContext.Object;
Microsoft.AspNetCore.SignalR.Core (1)
Internal\DefaultHubDispatcher.cs (1)
661hub.Context = connection.HubCallerContext;
101 references to Context
Microsoft.AspNetCore.Components.Server (39)
ComponentHub.cs (39)
78var circuitHost = _circuitHandleRegistry.GetCircuit(Context.Items, CircuitKey); 84return _circuitRegistry.DisconnectAsync(circuitHost, Context.ConnectionId); 89var circuitHost = _circuitHandleRegistry.GetCircuit(Context.Items, CircuitKey); 96Context.Abort(); 112Context.Abort(); 120Context.Abort(); 126var circuitClient = new CircuitClientProxy(Clients.Caller, Context.ConnectionId); 130var resourceCollection = Context.GetHttpContext().GetEndpoint()?.Metadata.GetMetadata<ResourceAssetCollection>(); 136Context.User, 144var httpActivityContext = Context.GetHttpContext().Features.Get<IHttpActivityFeature>()?.Activity.Context ?? default; 145_ = circuitHost.InitializeAsync(store, httpActivityContext, Context.ConnectionAborted); 150_circuitHandleRegistry.SetCircuit(Context.Items, CircuitKey, circuitHost); 155Log.CreatedCircuit(_logger, circuitHost.CircuitId, circuitHost.CircuitId.Secret, Context.ConnectionId); 164Context.Abort(); 198Context.Abort(); 208_ = circuitHost.UpdateRootComponents(operations, store, Context.ConnectionAborted); 225Context.ConnectionId, 226Context.ConnectionAborted); 229_circuitHandleRegistry.SetCircuit(Context.Items, CircuitKey, circuitHost); 230circuitHost.SetCircuitUser(Context.User); 286var circuitHost = _circuitHandleRegistry.GetCircuit(Context.Items, CircuitKey); 293Context.Abort(); 309Context.Abort(); 316persistedCircuitState = await _circuitPersistenceManager.ResumeCircuitAsync(circuitId, Context.ConnectionAborted); 321Context.Abort(); 333Context.Abort(); 346Context.Abort(); 352var circuitClient = new CircuitClientProxy(Clients.Caller, Context.ConnectionId); 353var resourceCollection = Context.GetHttpContext().GetEndpoint()?.Metadata.GetMetadata<ResourceAssetCollection>(); 359Context.User, 363var httpActivityContext = Context.GetHttpContext().Features.Get<IHttpActivityFeature>()?.Activity.Context ?? default; 369_ = circuitHost.InitializeAsync(store: null, httpActivityContext, Context.ConnectionAborted); 376_circuitHandleRegistry.SetCircuit(Context.Items, CircuitKey, circuitHost); 381Log.CreatedCircuit(_logger, circuitHost.CircuitId, circuitHost.CircuitId.Secret, Context.ConnectionId); 391Context.Abort(); 424_ = _circuitRegistry.PauseCircuitAsync(circuitHost, Context.ConnectionId); 558var handle = _circuitHandleRegistry.GetCircuitHandle(Context.Items, CircuitKey); 566Context.Abort(); 575Context.Abort();
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (16)
Hubs.cs (16)
33await Clients.Client(Context.ConnectionId).SendAsync("Echo", message); 38await Clients.Client(Context.ConnectionId).SendAsync("NoClientHandler"); 43return Context.ConnectionId; 54return Context.UserIdentifier; 59var context = Context.GetHttpContext(); 78return Context.GetHttpContext().Request.Cookies[cookieName]; 83var feature = Context.Features.Get<IHttpConnectionFeature>(); 98return Context.Features.Get<IHttpTransportFeature>().TransportType.ToString(); 103return Context.GetHttpContext()?.Request?.Protocol ?? "unknown"; 108Context.Abort(); 155await Clients.Client(Context.ConnectionId).Echo(message); 160await Clients.Client(Context.ConnectionId).NoClientHandler(); 165return Context.ConnectionId; 191await Clients.Client(Context.ConnectionId).Echo(message); 196await Clients.Client(Context.ConnectionId).NoClientHandler(); 201return 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"]; 1466string 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);