128 references to ReadAsync
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
RedisHubLifetimeManagerBenchmark.cs (1)
105while (await testClient.ReadAsync() != null)
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (1)
RedisHubLifetimeManagerTests.cs (1)
72var message = Assert.IsType<InvocationMessage>(await client2.ReadAsync().DefaultTimeout());
Microsoft.AspNetCore.SignalR.Tests (123)
HubConnectionHandlerTests.Activity.cs (4)
59var completionMessage = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 67Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 73Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 141var completionMessage = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout());
HubConnectionHandlerTests.ClientResult.cs (24)
28var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 33var completion = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 61var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 65var completion = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 91var closeMessage = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 119var closeMessage = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 148var message = await client.ReadAsync().DefaultTimeout(); 182var message = await client.ReadAsync().DefaultTimeout(); 217var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 223var completion = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 253var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 254var invocationMessage2 = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 255var invocationMessage3 = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 262var completion = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 268completion = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 274completion = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 301var task = await Task.WhenAny(tcsService.EndMethod.Task, client.ReadAsync()).DefaultTimeout(); 375var message = await client.ReadAsync().DefaultTimeout(); 420var message = await client.ReadAsync().DefaultTimeout(); 462var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 470var completion = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 500var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 505var streamItem = Assert.IsType<StreamItemMessage>(await client.ReadAsync().DefaultTimeout()); 509var completionMessage = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout());
HubConnectionHandlerTests.cs (95)
157var close = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 321var message = await client.ReadAsync(isHandshake: true).DefaultTimeout(); 352var task = client.ReadAsync(isHandshake: true); 393var task = client.ReadAsync(); 434var task = client.ReadAsync(isHandshake: true); 443var completionMessage = await client.ReadAsync() as CompletionMessage; 560var completionMessage = await client.ReadAsync().DefaultTimeout() as CompletionMessage; 565completionMessage = await client.ReadAsync().DefaultTimeout() as CompletionMessage; 571CloseMessage closeMessage = await client.ReadAsync().DefaultTimeout() as CloseMessage; 611var completionMessage = await client.ReadAsync().DefaultTimeout() as CompletionMessage; 616completionMessage = await client.ReadAsync().DefaultTimeout() as CompletionMessage; 621completionMessage = await client.ReadAsync().DefaultTimeout() as CompletionMessage; 676var handshakeReadTask = client.ReadAsync(true); 964var closeMessage = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 1144var closeMessage = await client.ReadAsync().DefaultTimeout(); 1386firstClient.ReadAsync(), 1387secondClient.ReadAsync()).DefaultTimeout()) 1424firstClient.ReadAsync(), 1425secondClient.ReadAsync()).DefaultTimeout()) 1461var secondClientResult = await secondClient.ReadAsync().DefaultTimeout(); 1466var firstClientResult = await firstClient.ReadAsync().DefaultTimeout(); 1470firstClientResult = await firstClient.ReadAsync().DefaultTimeout(); 1502var firstClientResult = await firstClient.ReadAsync().DefaultTimeout(); 1508var secondClientResult = await secondClient.ReadAsync().DefaultTimeout(); 1541var close = Assert.IsType<CloseMessage>(await firstClient.ReadAsync()); 1573var secondClientResult = await secondClient.ReadAsync().DefaultTimeout(); 1578var thirdClientResult = await thirdClient.ReadAsync().DefaultTimeout(); 1616var secondClientResult = await secondClient.ReadAsync().DefaultTimeout(); 1621var thirdClientResult = await thirdClient.ReadAsync().DefaultTimeout(); 1627var hubMessage = await firstClient.ReadAsync().DefaultTimeout(); 1661var secondClientResult = await secondClient.ReadAsync().DefaultTimeout(); 1666var thirdClientResult = await thirdClient.ReadAsync().DefaultTimeout(); 1672var hubMessage = await firstClient.ReadAsync().DefaultTimeout(); 1715var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1762var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1769hubMessage = await firstClient.ReadAsync().DefaultTimeout(); 1813var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1820hubMessage = await firstClient.ReadAsync().DefaultTimeout(); 1856var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1862hubMessage = await firstClient.ReadAsync().DefaultTimeout(); 1919var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1953var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1986var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 2059var hubMessage = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 2143var message1 = await client1.ReadAsync().DefaultTimeout(); 2144var message2 = await client2.ReadAsync().DefaultTimeout(); 2292var close = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 2397var message = (InvocationMessage)await client.ReadAsync().DefaultTimeout(); 2427var message = (InvocationMessage)await client.ReadAsync().DefaultTimeout(); 2467var message = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 2563var message = (InvocationMessage)await client1.ReadAsync().DefaultTimeout(); 2724while ((message = await client.ReadAsync()) != null) 2771while ((message = await client.ReadAsync().DefaultTimeout()) != null) 2824var result = await client.ReadAsync().DefaultTimeout(); 2923var result = await client.ReadAsync().DefaultTimeout(); 3047await client.ReadAsync().DefaultTimeout(); 3120var message = await client.ReadAsync().DefaultTimeout(); 3154var message = await client.ReadAsync().DefaultTimeout(); 3300var completion = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 3351var firstResult = await client.ReadAsync().DefaultTimeout(); 3357var secondResult = await client.ReadAsync().DefaultTimeout(); 3403var secondResult = await client.ReadAsync().DefaultTimeout(); 3413var firstResult = await client.ReadAsync().DefaultTimeout(); 3470var firstResult = await client.ReadAsync().DefaultTimeout(); 3476var secondResult = await client.ReadAsync().DefaultTimeout(); 3484firstResult = await client.ReadAsync().DefaultTimeout(); 3537completion = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 3572await client.ReadAsync().DefaultTimeout(); 3574var closeMessage = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 3612var result = (CompletionMessage)await client.ReadAsync().DefaultTimeout(5000); 3634var result = (CompletionMessage)await client.ReadAsync().DefaultTimeout(); 3658var response = (CompletionMessage)await client.ReadAsync().DefaultTimeout(); 3697var response = await client.ReadAsync().DefaultTimeout(); 3753var response = (CompletionMessage)await client.ReadAsync().DefaultTimeout(); 3787var response = (CompletionMessage)await client.ReadAsync().DefaultTimeout(); 3880var response = (CompletionMessage)await client.ReadAsync().DefaultTimeout(); 3929var response = await client.ReadAsync().DefaultTimeout(); 4003var response = (CompletionMessage)await client.ReadAsync().DefaultTimeout(); 4022var response = (CompletionMessage)await client.ReadAsync().DefaultTimeout(); 4041var response = (CompletionMessage)await client.ReadAsync().DefaultTimeout(); 4067var result = await client.ReadAsync().DefaultTimeout(); 4140var result = await client.ReadAsync().DefaultTimeout(); 4177var result = await client.ReadAsync().DefaultTimeout(); 4227var result = await client.ReadAsync().DefaultTimeout(); 4392var completion = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 4524var message = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 4550var message = await client.ReadAsync().DefaultTimeout(); 4640var message = await client.ReadAsync().DefaultTimeout(); 4723var response = Assert.IsType<CompletionMessage>(await client.ReadAsync().DefaultTimeout()); 5103var message = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 5125var message = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 5150var message = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 5214var readTask = client.ReadAsync(); 5258var seqMessage = Assert.IsType<SequenceMessage>(await client.ReadAsync().DefaultTimeout()); 5323var message = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout());
Microsoft.AspNetCore.SignalR.Tests.Utils (3)
TestClient.cs (3)
85HandshakeResponseMessage = (HandshakeResponseMessage)await ReadAsync(true).DefaultTimeout(); 122var message = await ReadAsync(); 155var message = await ReadAsync();