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