Pipe

21 instantiations of Pipe

Aspire.Cli.Tests (2)

Mcp\TestMcpServerTransport.cs (2)

25public Pipe ClientToServerPipe { get; } = new(); 30public Pipe ServerToClientPipe { get; } = new();

Aspire.Hosting.Tests (1)

Dcp\DcpExecutorTests.cs (1)

611var s = new Pipe();

Microsoft.AspNetCore.Components.Server (1)

Circuits\RemoteJSDataStream.cs (1)

78_pipe = new Pipe();

Microsoft.AspNetCore.Http.Connections (3)

Internal\HttpConnectionContext.cs (1)

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

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

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

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

Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)

548=> new Pipe(new PipeOptions

Internal\Http2\Http2Connection.cs (1)

169_input = new Pipe(GetInputPipeOptions());

Internal\Http2\Http2OutputProducer.cs (1)

763=> new Pipe(new PipeOptions

Internal\Http2\Http2Stream.cs (1)

646=> new Pipe(new PipeOptions

Internal\Http3\Http3OutputProducer.cs (1)

476=> new Pipe(new PipeOptions

Internal\Http3\Http3Stream.cs (1)

1239=> new Pipe(new PipeOptions

src\aspnetcore\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\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (2)

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

Microsoft.AspNetCore.Watch.BrowserRefresh (1)

src\sdk\src\Dotnet.Watch\Web.Middleware\ResponseStreamWrapper.cs (1)

138_pipe = new Pipe();

Microsoft.Extensions.Http.Diagnostics (1)

Logging\Internal\HttpResponseBodyReader.cs (1)

99var pipe = new Pipe();

53 references to Pipe

Aspire.Cli.Tests (2)

Mcp\TestMcpServerTransport.cs (2)

25public Pipe ClientToServerPipe { get; } = new(); 30public Pipe ServerToClientPipe { get; } = new();

Aspire.Hosting.Tests (8)

Dcp\DcpExecutorTests.cs (8)

608var logStreamPipesChannel = Channel.CreateUnbounded<(string Type, Pipe Pipe)>(); 611var s = new Pipe(); 836public Pipe StandardOut { get; set; } = default!; 837public Pipe StandardErr { get; set; } = default!; 838public Pipe StartupOut { get; set; } = default!; 839public Pipe StartupErr { get; set; } = default!; 840public Pipe System { get; set; } = default!; 843private static async Task<LogStreamPipes> GetStreamPipesAsync(Channel<(string Type, Pipe Pipe)> logStreamPipesChannel)

Microsoft.AspNetCore.Components.Server (1)

Circuits\RemoteJSDataStream.cs (1)

18private readonly Pipe _pipe;

Microsoft.AspNetCore.Http.Connections (3)

Internal\HttpConnectionContext.cs (1)

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

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

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

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

Internal\Http\Http1ChunkedEncodingMessageBody.cs (2)

28private readonly Pipe _requestBodyPipe; 547private static Pipe CreateRequestBodyPipe(Http1Connection context)

Internal\Http2\Http2Connection.cs (1)

112private readonly Pipe _input;

Internal\Http2\Http2OutputProducer.cs (2)

32private readonly Pipe _pipe; 762private static Pipe CreateDataPipe(MemoryPool<byte> pool, bool scheduleInline)

Internal\Http2\Http2Stream.cs (2)

42public Pipe RequestBodyPipe { get; private set; } = default!; 645private Pipe CreateRequestBodyPipe()

Internal\Http3\Http3OutputProducer.cs (2)

24private readonly Pipe _pipe; 475private static Pipe CreateDataPipe(MemoryPool<byte> pool)

Internal\Http3\Http3Stream.cs (2)

86public Pipe RequestBodyPipe { get; private set; } = default!; 1238private Pipe CreateRequestBodyPipe(uint windowSize)

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (4)

7/// A <see cref="Pipe"/> is a reader-writer pair, where content written to the writer can be read from the reader. 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

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

Internal\QuicStreamContext.cs (2)

26private readonly Pipe _inputPipe; 27private readonly Pipe _outputPipe;

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (4)

Microsoft.AspNetCore.Watch.BrowserRefresh (1)

src\sdk\src\Dotnet.Watch\Web.Middleware\ResponseStreamWrapper.cs (1)

34private Pipe? _pipe;

Microsoft.Extensions.Http.Diagnostics (1)

Logging\Internal\HttpResponseBodyReader.cs (1)

99var pipe = new Pipe();

System.IO.Pipelines (16)

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

17private static readonly Action<object?> s_signalReaderAwaitable = state => ((Pipe)state!).ReaderCancellationRequested(); 18private static readonly Action<object?> s_signalWriterAwaitable = state => ((Pipe)state!).WriterCancellationRequested(); 86/// <summary>Initializes a new instance of the <see cref="System.IO.Pipelines.Pipe" /> class using <see cref="System.IO.Pipelines.PipeOptions.Default" /> as options.</summary> 91/// <summary>Initializes a new instance of the <see cref="System.IO.Pipelines.Pipe" /> class with the specified options.</summary>

System\IO\Pipelines\Pipe.DefaultPipeReader.cs (2)

15private readonly Pipe _pipe; 17public DefaultPipeReader(Pipe pipe)

System\IO\Pipelines\Pipe.DefaultPipeWriter.cs (2)

15private readonly Pipe _pipe; 17public DefaultPipeWriter(Pipe pipe)

System\IO\Pipelines\PipeOptions.cs (8)