4 instantiations of DuplexPipe
Microsoft.AspNetCore.SignalR.Tests (4)
Internal\MessageBufferTests.cs (4)
725var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 726var applicationToTransport = new DuplexPipe(input.Reader, output.Writer); 749var transportToApplication = new DuplexPipe(duplexPipePair.Transport.Input, input.Writer); 750var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.Application.Output);
32 references to DuplexPipe
Microsoft.AspNetCore.SignalR.Tests (32)
Internal\MessageBufferTests.cs (32)
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); 618var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 633DuplexPipe.UpdateConnectionPair(ref pipes, connection, pipeOptions); 662var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 677DuplexPipe.UpdateConnectionPair(ref pipes, connection, pipeOptions); 725var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 726var applicationToTransport = new DuplexPipe(input.Reader, output.Writer); 749var transportToApplication = new DuplexPipe(duplexPipePair.Transport.Input, input.Writer); 750var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.Application.Output);