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