2 writes to Application
Microsoft.AspNetCore.SignalR.Tests (2)
Internal\MessageBufferTests.cs (2)
652
Application
= application;
664
duplexPipePair.
Application
= applicationToTransport;
67 references to Application
Microsoft.AspNetCore.SignalR.Tests (67)
Internal\MessageBufferTests.cs (67)
36
var res = await pipes.
Application
.Input.ReadAsync().DefaultTimeout();
42
pipes.
Application
.Input.AdvanceTo(buffer.Start);
62
var res = await pipes.
Application
.Input.ReadAsync();
68
pipes.
Application
.Input.AdvanceTo(buffer.Start);
76
res = await pipes.
Application
.Input.ReadAsync().DefaultTimeout();
82
pipes.
Application
.Input.AdvanceTo(buffer.Start);
105
var res = await pipes.
Application
.Input.ReadAsync();
110
pipes.
Application
.Input.AdvanceTo(buffer.Start);
114
res = await pipes.
Application
.Input.ReadAsync();
119
pipes.
Application
.Input.AdvanceTo(buffer.Start);
122
Assert.False(pipes.
Application
.Input.TryRead(out res));
139
var res = await pipes.
Application
.Input.ReadAsync();
145
pipes.
Application
.Input.AdvanceTo(buffer.Start);
154
res = await pipes.
Application
.Input.ReadAsync();
161
pipes.
Application
.Input.AdvanceTo(buffer.Start);
163
res = await pipes.
Application
.Input.ReadAsync();
169
pipes.
Application
.Input.AdvanceTo(buffer.Start);
192
var res = await pipes.
Application
.Input.ReadAsync();
200
pipes.
Application
.Input.AdvanceTo(buffer.Start);
209
res = await pipes.
Application
.Input.ReadAsync();
216
pipes.
Application
.Input.AdvanceTo(buffer.Start);
218
res = await pipes.
Application
.Input.ReadAsync();
226
pipes.
Application
.Input.AdvanceTo(buffer.Start);
246
var res = await pipes.
Application
.Input.ReadAsync();
252
pipes.
Application
.Input.AdvanceTo(buffer.Start);
259
res = await pipes.
Application
.Input.ReadAsync();
266
pipes.
Application
.Input.AdvanceTo(buffer.Start);
270
res = await pipes.
Application
.Input.ReadAsync();
276
pipes.
Application
.Input.AdvanceTo(buffer.Start);
291
var res = await pipes.
Application
.Input.ReadAsync();
298
pipes.
Application
.Input.AdvanceTo(buffer.Start);
324
var res = await pipes.
Application
.Input.ReadAsync();
331
pipes.
Application
.Input.AdvanceTo(buffer.Start);
335
res = await pipes.
Application
.Input.ReadAsync();
341
pipes.
Application
.Input.AdvanceTo(buffer.Start);
344
Assert.False(pipes.
Application
.Input.TryRead(out res));
362
var res = await pipes.
Application
.Input.ReadAsync();
368
pipes.
Application
.Input.AdvanceTo(buffer.Start);
376
res = await pipes.
Application
.Input.ReadAsync().DefaultTimeout();
382
pipes.
Application
.Input.AdvanceTo(buffer.Start);
398
pipes.
Application
.Input.Complete();
408
var res = await pipes.
Application
.Input.ReadAsync();
413
pipes.
Application
.Input.AdvanceTo(buffer.Start);
417
res = await pipes.
Application
.Input.ReadAsync();
422
pipes.
Application
.Input.AdvanceTo(buffer.Start);
425
Assert.False(pipes.
Application
.Input.TryRead(out res));
444
var res = await pipes.
Application
.Input.ReadAsync();
448
pipes.
Application
.Input.AdvanceTo(buffer.Start);
456
res = await pipes.
Application
.Input.ReadAsync();
460
pipes.
Application
.Input.AdvanceTo(buffer.Start);
489
var res = await pipes.
Application
.Input.ReadAsync();
493
pipes.
Application
.Input.AdvanceTo(buffer.Start);
497
res = await pipes.
Application
.Input.ReadAsync();
501
pipes.
Application
.Input.AdvanceTo(buffer.Start);
537
var res = await pipes.
Application
.Input.ReadAsync();
541
pipes.
Application
.Input.AdvanceTo(buffer.Start);
547
res = await pipes.
Application
.Input.ReadAsync();
551
pipes.
Application
.Input.AdvanceTo(buffer.Start);
556
res = await pipes.
Application
.Input.ReadAsync();
560
pipes.
Application
.Input.AdvanceTo(buffer.Start);
562
Assert.False(pipes.
Application
.Input.TryRead(out res));
589
var res = await pipes.
Application
.Input.ReadAsync();
594
pipes.
Application
.Input.AdvanceTo(buffer.Start);
598
res = await pipes.
Application
.Input.ReadAsync();
603
pipes.
Application
.Input.AdvanceTo(buffer.Start);
606
Assert.False(pipes.
Application
.Input.TryRead(out res));
662
var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.
Application
.Output);