DuplexPipe

7 instantiations of DuplexPipe

Microsoft.AspNetCore.Http.Connections.Client (4)

Internal\WebSocketsTransport.cs (2)

710var transportToApplication = new DuplexPipe(_transport!.Input, input.Writer); 711var 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);

Microsoft.AspNetCore.SignalR.Client.Tests (1)

SendUtilsTests.cs (1)

38var application = new DuplexPipe(pipe.Reader, pipe.Writer);

Microsoft.AspNetCore.SignalR.Tests (2)

HubConnectionHandlerTests.cs (2)

5307var transportToApplication = new DuplexPipe(connection.Transport.Input, input.Writer); 5308var applicationToTransport = new DuplexPipe(input.Reader, connection.Application.Output);

15 references to DuplexPipe

Microsoft.AspNetCore.Http.Connections.Client (7)

Internal\LongPollingTransport.cs (1)

63var pair = DuplexPipe.CreateConnectionPair(_httpConnectionOptions.TransportPipeOptions, _httpConnectionOptions.AppPipeOptions);

Internal\ServerSentEventsTransport.cs (1)

75var pair = DuplexPipe.CreateConnectionPair(_httpConnectionOptions.TransportPipeOptions, _httpConnectionOptions.AppPipeOptions);

Internal\WebSocketsTransport.cs (3)

24using static System.IO.Pipelines.DuplexPipe; 710var transportToApplication = new DuplexPipe(_transport!.Input, input.Writer); 711var 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);

Microsoft.AspNetCore.SignalR.Client.Tests (3)

SendUtilsTests.cs (1)

38var application = new DuplexPipe(pipe.Reader, pipe.Writer);

TestConnection.cs (1)

57var pair = DuplexPipe.CreateConnectionPair(options, options);

TestTransport.cs (1)

44var pair = DuplexPipe.CreateConnectionPair(options, options);

Microsoft.AspNetCore.SignalR.Microbenchmarks (2)

BroadcastBenchmark.cs (1)

44var pair = DuplexPipe.CreateConnectionPair(options, options);

DefaultHubDispatcherBenchmark.cs (1)

42var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);

Microsoft.AspNetCore.SignalR.Tests (3)

EndToEndTests.cs (1)

722var pair = DuplexPipe.CreateConnectionPair(options, options);

HubConnectionHandlerTests.cs (2)

5307var transportToApplication = new DuplexPipe(connection.Transport.Input, input.Writer); 5308var applicationToTransport = new DuplexPipe(input.Reader, connection.Application.Output);