DuplexPipe

15 references to DuplexPipe

InMemory.FunctionalTests (3)

Http3\WebTransport\WebTransportTestUtilities.cs (1)

86var transport = new DuplexPipe(new StreamReader(memory), writer);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

1147new DuplexPipe(_transportPipeReader, _transportPipeWriter), 1148new DuplexPipe(_outputPipe.Reader, _inputPipe.Writer));

Microsoft.AspNetCore.Server.Kestrel.Core (3)

Internal\WebTransport\WebTransportStream.cs (1)

60_duplexPipe = new DuplexPipe(context.Transport.Input, context.Transport.Output);

src\Shared\ServerInfrastructure\DuplexPipe.cs (2)

36var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 37var applicationToTransport = new DuplexPipe(input.Reader, output.Writer);

Microsoft.AspNetCore.Server.Kestrel.Core.Tests (7)

HttpConnectionTests.cs (1)

28transport: new DuplexPipe(Mock.Of<PipeReader>(), Mock.Of<PipeWriter>()));

TlsListenerTests.cs (6)

64var transport = new DuplexPipe(reader, writer); 86var transport = new DuplexPipe(reader, writer); 109var transport = new DuplexPipe(reader, writer); 138var transport = new DuplexPipe(reader, writer); 169var transport = new DuplexPipe(pipe.Reader, writer); 222var transport = new DuplexPipe(pipe.Reader, writer);

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (2)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

1147new DuplexPipe(_transportPipeReader, _transportPipeWriter), 1148new DuplexPipe(_outputPipe.Reader, _inputPipe.Writer));