37 references to DefaultTimeout
Microsoft.AspNetCore.SignalR.Specification.Tests (37)
HubLifetimeManagerTestBase.cs (21)
48var message = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 53message = Assert.IsType<InvocationMessage>(await client2.ReadAsync().DefaultTimeout()); 81var message = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 111var message = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 142var message = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 167var message = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 190var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 196var res = await resultTask.DefaultTimeout(); 217var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 223var ex = await Assert.ThrowsAsync<HubException>(() => resultTask).DefaultTimeout(); 247var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 252manager.SetConnectionResultAsync(connection2.ConnectionId, CompletionMessage.WithError(invocation.InvocationId, "Error from client"))).DefaultTimeout(); 259var res = await resultTask.DefaultTimeout(); 280await Assert.ThrowsAsync<IOException>(() => manager1.InvokeConnectionAsync<int>("none", "Result", new object[] { "test" }, cancellationToken: default)).DefaultTimeout(); 305var invocation1 = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 306var invocation2 = Assert.IsType<InvocationMessage>(await client2.ReadAsync().DefaultTimeout()); 309await Assert.ThrowsAnyAsync<Exception>(() => invoke2).DefaultTimeout(); 313Assert.Equal(3, await invoke1.DefaultTimeout()); 337var ex = await Assert.ThrowsAsync<IOException>(() => invoke1).DefaultTimeout(); 359var invocation1 = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 362await Assert.ThrowsAsync<HubException>(() => invoke1).DefaultTimeout();
ScaleoutHubLifetimeManagerTests.cs (15)
32var message = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 486var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 493var res = await resultTask.DefaultTimeout(); 517var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 524var ex = await Assert.ThrowsAsync<HubException>(() => resultTask).DefaultTimeout(); 547await Assert.ThrowsAsync<IOException>(() => manager1.InvokeConnectionAsync<int>("none", "Result", new object[] { "test" }, cancellationToken: default)).DefaultTimeout(); 569var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 575var ex = await Assert.ThrowsAsync<HubException>(() => invoke1).DefaultTimeout(); 598var invocation2 = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 601var invocation1 = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 608var res = await invoke1.DefaultTimeout(); 610res = await invoke2.DefaultTimeout(); 626var ex = await Assert.ThrowsAsync<IOException>(() => manager1.InvokeConnectionAsync<int>("1234", "Result", new object[] { "test" }, cancellationToken: default)).DefaultTimeout(); 649var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 656var ex = await Assert.ThrowsAsync<HubException>(() => resultTask).DefaultTimeout();
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (1)
85HandshakeResponseMessage = (HandshakeResponseMessage)await ReadAsync(true).DefaultTimeout();