DuplexPipe

4 instantiations of DuplexPipe

Microsoft.AspNetCore.Http.Connections.Client (4)

Internal\WebSocketsTransport.cs (2)

710var transportToApplication = new DuplexPipe(_transport!.Input, input.Writer); 711var applicationToTransport = new DuplexPipe(input.Reader, _application!.Output);

src\SignalR\common\Shared\DuplexPipe.cs (2)

23var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 24var applicationToTransport = new DuplexPipe(input.Reader, output.Writer);

7 references to DuplexPipe

Microsoft.AspNetCore.Http.Connections.Client (7)

Internal\LongPollingTransport.cs (1)

63var pair = DuplexPipe.CreateConnectionPair(_httpConnectionOptions.TransportPipeOptions, _httpConnectionOptions.AppPipeOptions);

Internal\ServerSentEventsTransport.cs (1)

75var pair = DuplexPipe.CreateConnectionPair(_httpConnectionOptions.TransportPipeOptions, _httpConnectionOptions.AppPipeOptions);

Internal\WebSocketsTransport.cs (3)

24using static System.IO.Pipelines.DuplexPipe; 710var transportToApplication = new DuplexPipe(_transport!.Input, input.Writer); 711var applicationToTransport = new DuplexPipe(input.Reader, _application!.Output);

src\SignalR\common\Shared\DuplexPipe.cs (2)

23var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 24var applicationToTransport = new DuplexPipe(input.Reader, output.Writer);