DuplexPipe

Http3\WebTransport\WebTransportTestUtilities.cs (1)

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

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

1165new DuplexPipe(_transportPipeReader, _transportPipeWriter), 1166new DuplexPipe(_outputPipe.Reader, _inputPipe.Writer));

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);

HttpConnectionTests.cs (1)

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

TlsListenerTests.cs (7)

64var transport = new DuplexPipe(reader, writer); 86var transport = new DuplexPipe(reader, writer); 109var transport = new DuplexPipe(reader, writer); 138var transport = new DuplexPipe(reader, writer); 189var transport = new DuplexPipe(pipe.Reader, writer); 217var transport = new DuplexPipe(pipe.Reader, writer); 270var transport = new DuplexPipe(pipe.Reader, writer);

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

1165new DuplexPipe(_transportPipeReader, _transportPipeWriter), 1166new DuplexPipe(_outputPipe.Reader, _inputPipe.Writer));

Http2\Http2TestBase.cs (2)

157internal DuplexPipe.DuplexPipePair _pair; 474_pair = DuplexPipe.CreateConnectionPair(inputPipeOptions, outputPipeOptions);

Http3\WebTransport\WebTransportTestUtilities.cs (1)

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

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

25using static System.IO.Pipelines.DuplexPipe; 500internal DuplexPipe.DuplexPipePair Pair { get; }

TestTransport\InMemoryTransportConnection.cs (1)

32var pair = DuplexPipe.CreateConnectionPair(new PipeOptions(memoryPool, readerScheduler: scheduler, useSynchronizationContext: false), new PipeOptions(memoryPool, writerScheduler: scheduler, useSynchronizationContext: false));

Internal\WebTransport\WebTransportStream.cs (1)

21private readonly DuplexPipe _duplexPipe;

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

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

Http1\Http1ConnectionTestsBase.cs (1)

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

Http3\Http3HttpProtocolFeatureCollectionTests.cs (1)

24transport: DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()).Application,

HttpResponseHeadersTests.cs (1)

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

StartLineTests.cs (1)

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

TestHelpers\TestInput.cs (1)

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

TlsListenerTests.cs (7)

64var transport = new DuplexPipe(reader, writer); 86var transport = new DuplexPipe(reader, writer); 109var transport = new DuplexPipe(reader, writer); 138var transport = new DuplexPipe(reader, writer); 189var transport = new DuplexPipe(pipe.Reader, writer); 217var transport = new DuplexPipe(pipe.Reader, writer); 270var transport = new DuplexPipe(pipe.Reader, writer);

HeaderCollectionBenchmark.cs (1)

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

Http1ConnectionBenchmark.cs (1)

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

Http1ConnectionParsingOverheadBenchmark.cs (1)

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

Http1LargeWritingBenchmark.cs (2)

21private DuplexPipe.DuplexPipePair _pair; 68var pair = DuplexPipe.CreateConnectionPair(options, options);

Http1ReadingBenchmark.cs (2)

30private DuplexPipe.DuplexPipePair _pair; 97var pair = DuplexPipe.CreateConnectionPair(options, options);

Http1WritingBenchmark.cs (2)

29private DuplexPipe.DuplexPipePair _pair; 102var pair = DuplexPipe.CreateConnectionPair(options, options);

Http2\Http2ConnectionBenchmarkBase.cs (2)

32private DuplexPipe.DuplexPipePair _connectionPair; 50_connectionPair = DuplexPipe.CreateConnectionPair(options, options);

HttpProtocolFeatureCollection.cs (1)

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

InMemoryTransportBenchmark.cs (1)

175var pair = DuplexPipe.CreateConnectionPair(inputOptions, outputOptions);

RequestParsingBenchmark.cs (1)

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

ResponseHeaderCollectionBenchmark.cs (1)

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

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

25using static System.IO.Pipelines.DuplexPipe; 500internal DuplexPipe.DuplexPipePair Pair { get; }