4 instantiations of DuplexPipe
Microsoft.AspNetCore.Http.Connections (4)
Internal\HttpConnectionContext.cs (2)
712
var transportToApplication = new
DuplexPipe
(Transport.Input, input.Writer);
713
var applicationToTransport = new
DuplexPipe
(input.Reader, Application.Output);
src\SignalR\common\Shared\DuplexPipe.cs (2)
23
var transportToApplication = new
DuplexPipe
(output.Reader, input.Writer);
24
var applicationToTransport = new
DuplexPipe
(input.Reader, output.Writer);
24 references to DuplexPipe
Microsoft.AspNetCore.Http.Connections (5)
Internal\HttpConnectionContext.cs (2)
712
var
transportToApplication = new DuplexPipe(Transport.Input, input.Writer);
713
var
applicationToTransport = new DuplexPipe(input.Reader, Application.Output);
Internal\HttpConnectionManager.cs (1)
13
using static System.IO.Pipelines.
DuplexPipe
;
src\SignalR\common\Shared\DuplexPipe.cs (2)
23
var
transportToApplication = new DuplexPipe(output.Reader, input.Writer);
24
var
applicationToTransport = new DuplexPipe(input.Reader, output.Writer);
Microsoft.AspNetCore.Http.Connections.Tests (19)
LongPollingTests.cs (4)
25
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
45
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
67
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
90
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
ServerSentEventsTests.cs (5)
24
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
45
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
66
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, new PipeOptions(readerScheduler: PipeScheduler.Inline));
88
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, new PipeOptions(readerScheduler: PipeScheduler.Inline));
116
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
WebSocketsTests.cs (10)
33
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
80
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
111
private HttpConnectionContext CreateHttpConnectionContext(
DuplexPipe
.DuplexPipePair pair, string loggerName = null)
122
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
174
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
205
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
239
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
273
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
312
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
354
var pair =
DuplexPipe
.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);