1 write to Connection
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (1)
46Connection = new DefaultConnectionContext(Guid.NewGuid().ToString(), pair.Transport, pair.Application);
60 references to Connection
Microsoft.AspNetCore.SignalR.Specification.Tests (60)
HubLifetimeManagerTestBase.cs (18)
40var connection1 = HubConnectionContextUtils.Create(client1.Connection); 41var connection2 = HubConnectionContextUtils.Create(client2.Connection); 71var connection1 = HubConnectionContextUtils.Create(client1.Connection); 72var connection2 = HubConnectionContextUtils.Create(client2.Connection); 101var connection1 = HubConnectionContextUtils.Create(client1.Connection); 102var connection2 = HubConnectionContextUtils.Create(client2.Connection); 131var connection1 = HubConnectionContextUtils.Create(client1.Connection); 132var connection2 = HubConnectionContextUtils.Create(client2.Connection); 161var connection = HubConnectionContextUtils.Create(client.Connection); 185var connection1 = HubConnectionContextUtils.Create(client1.Connection); 212var connection1 = HubConnectionContextUtils.Create(client1.Connection); 240var connection1 = HubConnectionContextUtils.Create(client1.Connection); 241var connection2 = HubConnectionContextUtils.Create(client2.Connection); 275var connection1 = HubConnectionContextUtils.Create(client1.Connection); 296var connection1 = HubConnectionContextUtils.Create(client1.Connection); 297var connection2 = HubConnectionContextUtils.Create(client2.Connection); 328var connection1 = HubConnectionContextUtils.Create(client1.Connection); 353var connection1 = HubConnectionContextUtils.Create(client1.Connection);
ScaleoutHubLifetimeManagerTests.cs (29)
52var connection1 = HubConnectionContextUtils.Create(client1.Connection); 53var connection2 = HubConnectionContextUtils.Create(client2.Connection); 79var connection1 = HubConnectionContextUtils.Create(client1.Connection); 80var connection2 = HubConnectionContextUtils.Create(client2.Connection); 109var connection = HubConnectionContextUtils.Create(client.Connection); 133var connection = HubConnectionContextUtils.Create(client.Connection); 157var connection = HubConnectionContextUtils.Create(client.Connection); 183var connection = HubConnectionContextUtils.Create(client.Connection); 204var connection = HubConnectionContextUtils.Create(client.Connection); 225var connection = HubConnectionContextUtils.Create(client.Connection); 249var connection = HubConnectionContextUtils.Create(client.Connection); 276var connection = HubConnectionContextUtils.Create(client.Connection); 303var connection = HubConnectionContextUtils.Create(client.Connection); 334var connection = HubConnectionContextUtils.Create(client.Connection); 361var connectionMock = HubConnectionContextUtils.CreateMock(client.Connection); 385var connectionMock = HubConnectionContextUtils.CreateMock(client1.Connection); 388var connection2 = HubConnectionContextUtils.Create(client2.Connection); 420var connection1 = HubConnectionContextUtils.Create(client1.Connection, userIdentifier: "userA"); 421var connection2 = HubConnectionContextUtils.Create(client2.Connection, userIdentifier: "userA"); 422var connection3 = HubConnectionContextUtils.Create(client3.Connection, userIdentifier: "userB"); 448var connection1 = HubConnectionContextUtils.Create(client1.Connection, userIdentifier: "userA"); 449var connection2 = HubConnectionContextUtils.Create(client2.Connection, userIdentifier: "userA"); 450var connection3 = HubConnectionContextUtils.Create(client3.Connection, userIdentifier: "userB"); 480var connection1 = HubConnectionContextUtils.Create(client1.Connection); 511var connection1 = HubConnectionContextUtils.Create(client1.Connection); 542var connection1 = HubConnectionContextUtils.Create(client1.Connection); 564var connection1 = HubConnectionContextUtils.Create(client1.Connection); 593var connection = HubConnectionContextUtils.Create(client.Connection); 643var connection1 = HubConnectionContextUtils.Create(client1.Connection);
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (13)
34public Task Connected => ((TaskCompletionSource)Connection.Items["ConnectedTask"]).Task; 49Connection.Features.Set<ITransferFormatFeature>(this); 50Connection.Features.Set<IConnectionHeartbeatFeature>(this); 59Connection.User = new ClaimsPrincipal(new ClaimsIdentity(claims)); 60Connection.Items["ConnectedTask"] = new TaskCompletionSource(); 75await Connection.Application.Output.WriteAsync(GetHandshakeRequestMessage()); 78var connection = handler.OnConnectedAsync(Connection); 215await Connection.Application.Output.WriteAsync(payload); 227var result = await Connection.Application.Input.ReadAsync(); 244Connection.Application.Input.AdvanceTo(buffer.Start); 256if (!Connection.Application.Input.TryRead(out var result)) 283Connection.Application.Input.AdvanceTo(buffer.Start); 293Connection.Application.Output.Complete();