Pipe

56 references to Pipe

ClientSample (2)

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

InMemory.FunctionalTests (3)

Http2\PipeReaderFactory.cs (1)

24var pipe = new Pipe(options);

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

1133_inputPipe = new Pipe(inputOptions); 1134_outputPipe = new Pipe(outputOptions);

Microsoft.AspNetCore.Http.Connections (3)

Internal\HttpConnectionContext.cs (1)

709var input = new Pipe(_options.TransportPipeOptions);

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

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

Internal\WebSocketsTransport.cs (1)

707var input = new Pipe(_httpConnectionOptions.TransportPipeOptions);

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

Microsoft.AspNetCore.Server.IIS (4)

Core\IISHttpContext.cs (2)

305var pipe = new Pipe(new PipeOptions( 502_bodyInputPipe = new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.ThreadPool, minimumSegmentSize: MinAllocBufferSize));

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

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

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

Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)

517=> new Pipe(new PipeOptions

Internal\Http2\Http2Connection.cs (1)

165_input = new Pipe(GetInputPipeOptions());

Internal\Http2\Http2OutputProducer.cs (1)

766=> new Pipe(new PipeOptions

Internal\Http2\Http2Stream.cs (1)

647=> new Pipe(new PipeOptions

Internal\Http3\Http3OutputProducer.cs (1)

478=> new Pipe(new PipeOptions

Internal\Http3\Http3Stream.cs (1)

1183=> new Pipe(new PipeOptions

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

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

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

BufferWriterTests.cs (1)

16Pipe = new Pipe(new PipeOptions(useSynchronizationContext: false, pauseWriterThreshold: 0, resumeWriterThreshold: 0));

Http1\Http1OutputProducerTests.cs (1)

231var pipe = new Pipe(pipeOptions);

Http2\Http2FrameWriterTests.cs (3)

38var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline)); 60var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline)); 76var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline));

Http3\Http3FrameWriterTests.cs (3)

41var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline)); 55var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline)); 74var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline));

PipelineExtensionTests.cs (1)

23_pipe = new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false));

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

ChunkWriterBenchmark.cs (1)

24var pipe = new Pipe(new PipeOptions(_memoryPool));

Http2\Http2FrameWriterBenchmark.cs (1)

30_pipe = new Pipe(options);

PipeThroughputBenchmark.cs (1)

23_pipe = new Pipe(new PipeOptions(_memoryPool));

RequestParsingBenchmark.cs (1)

49Pipe = new Pipe(new PipeOptions(_memoryPool));

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

1133_inputPipe = new Pipe(inputOptions); 1134_outputPipe = new Pipe(outputOptions);

Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (2)

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

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (4)

Internal\QuicStreamContext.cs (2)

63_inputPipe = new Pipe(inputOptions); 64_outputPipe = new Pipe(outputOptions);

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

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (2)

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

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

Microsoft.AspNetCore.Shared.Tests (2)

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

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

Microsoft.AspNetCore.SignalR.Specification.Tests (2)

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

Microsoft.AspNetCore.SignalR.Tests (3)

Internal\MessageBufferTests.cs (3)

520var input = new Pipe(inputOptions); 521var output = new Pipe(outputOptions); 544var input = new Pipe(pipeOptions ?? new PipeOptions());

Microsoft.AspNetCore.SignalR.Tests.Utils (2)

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

System.IO.Pipelines (1)

System\IO\Pipelines\Pipe.cs (1)

87public Pipe() : this(PipeOptions.Default)