4 instantiations of DuplexPipe
Microsoft.AspNetCore.SignalR.Tests (4)
Internal\MessageBufferTests.cs (4)
580var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 581var applicationToTransport = new DuplexPipe(input.Reader, output.Writer); 604var transportToApplication = new DuplexPipe(duplexPipePair.Transport.Input, input.Writer); 605var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.Application.Output);
26 references to DuplexPipe
Microsoft.AspNetCore.SignalR.Tests (26)
Internal\MessageBufferTests.cs (26)
23var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 51var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions(pauseWriterThreshold: 200000, resumeWriterThreshold: 100000)); 89var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 99DuplexPipe.UpdateConnectionPair(ref pipes, connection, pipeOptions); 129var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 143DuplexPipe.UpdateConnectionPair(ref pipes, connection); 179var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 197DuplexPipe.UpdateConnectionPair(ref pipes, connection); 234var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 250DuplexPipe.UpdateConnectionPair(ref pipes, connection); 278var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 282DuplexPipe.UpdateConnectionPair(ref pipes, connection); 302var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 314DuplexPipe.UpdateConnectionPair(ref pipes, connection); 345var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 382var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 396DuplexPipe.UpdateConnectionPair(ref pipes, connection); 424var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 462var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 472DuplexPipe.UpdateConnectionPair(ref pipes, connection, new PipeOptions(pauseWriterThreshold: 100, resumeWriterThreshold: 50)); 504var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 513DuplexPipe.UpdateConnectionPair(ref pipes, connection, pipeOptions); 580var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 581var applicationToTransport = new DuplexPipe(input.Reader, output.Writer); 604var transportToApplication = new DuplexPipe(duplexPipePair.Transport.Input, input.Writer); 605var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.Application.Output);