4 instantiations of DuplexPipe
Microsoft.AspNetCore.SignalR.Tests (4)
Internal\MessageBufferTests.cs (4)
637var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 638var applicationToTransport = new DuplexPipe(input.Reader, output.Writer); 661var transportToApplication = new DuplexPipe(duplexPipePair.Transport.Input, input.Writer); 662var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.Application.Output);
28 references to DuplexPipe
Microsoft.AspNetCore.SignalR.Tests (28)
Internal\MessageBufferTests.cs (28)
24var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 53var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions(pauseWriterThreshold: 200000, resumeWriterThreshold: 100000)); 92var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 102DuplexPipe.UpdateConnectionPair(ref pipes, connection, pipeOptions); 133var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 147DuplexPipe.UpdateConnectionPair(ref pipes, connection); 184var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 202DuplexPipe.UpdateConnectionPair(ref pipes, connection); 240var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 256DuplexPipe.UpdateConnectionPair(ref pipes, connection); 284var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 288DuplexPipe.UpdateConnectionPair(ref pipes, connection); 309var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 321DuplexPipe.UpdateConnectionPair(ref pipes, connection); 353var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 391var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 405DuplexPipe.UpdateConnectionPair(ref pipes, connection); 433var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 472var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 482DuplexPipe.UpdateConnectionPair(ref pipes, connection, new PipeOptions(pauseWriterThreshold: 100, resumeWriterThreshold: 50)); 515var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 524DuplexPipe.UpdateConnectionPair(ref pipes, connection, pipeOptions); 572var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 586DuplexPipe.UpdateConnectionPair(ref pipes, connection, pipeOptions); 637var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 638var applicationToTransport = new DuplexPipe(input.Reader, output.Writer); 661var transportToApplication = new DuplexPipe(duplexPipePair.Transport.Input, input.Writer); 662var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.Application.Output);