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