4 instantiations of DuplexPipe
Microsoft.AspNetCore.SignalR.Tests (4)
Internal\MessageBufferTests.cs (4)
523var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 524var applicationToTransport = new DuplexPipe(input.Reader, output.Writer); 547var transportToApplication = new DuplexPipe(duplexPipePair.Transport.Input, input.Writer); 548var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.Application.Output);
24 references to DuplexPipe
Microsoft.AspNetCore.SignalR.Tests (24)
Internal\MessageBufferTests.cs (24)
22var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 50var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions(pauseWriterThreshold: 200000, resumeWriterThreshold: 100000)); 88var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 98DuplexPipe.UpdateConnectionPair(ref pipes, connection, pipeOptions); 128var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 142DuplexPipe.UpdateConnectionPair(ref pipes, connection); 177var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 193DuplexPipe.UpdateConnectionPair(ref pipes, connection); 221var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 225DuplexPipe.UpdateConnectionPair(ref pipes, connection); 245var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 257DuplexPipe.UpdateConnectionPair(ref pipes, connection); 288var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 325var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 339DuplexPipe.UpdateConnectionPair(ref pipes, connection); 367var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 405var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 415DuplexPipe.UpdateConnectionPair(ref pipes, connection, new PipeOptions(pauseWriterThreshold: 100, resumeWriterThreshold: 50)); 447var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 456DuplexPipe.UpdateConnectionPair(ref pipes, connection, pipeOptions); 523var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 524var applicationToTransport = new DuplexPipe(input.Reader, output.Writer); 547var transportToApplication = new DuplexPipe(duplexPipePair.Transport.Input, input.Writer); 548var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.Application.Output);