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)
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.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)
9/// <summary>Represents a set of <see cref="System.IO.Pipelines.Pipe" /> options.</summary> 22/// <param name="pauseWriterThreshold">The number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> before <see cref="System.IO.Pipelines.PipeWriter.FlushAsync(System.Threading.CancellationToken)" /> starts blocking. A value of zero prevents <see cref="System.IO.Pipelines.PipeWriter.FlushAsync(System.Threading.CancellationToken)" /> from ever blocking, effectively making the number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> unlimited.</param> 23/// <param name="resumeWriterThreshold">The number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> when <see cref="System.IO.Pipelines.PipeWriter.FlushAsync(System.Threading.CancellationToken)" /> stops blocking.</param> 92/// <summary>Gets the number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> when <see cref="System.IO.Pipelines.PipeWriter.FlushAsync(System.Threading.CancellationToken)" /> starts blocking.</summary> 93/// <value>The number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> when <see cref="System.IO.Pipelines.PipeWriter.FlushAsync(System.Threading.CancellationToken)" /> starts blocking.</value> 96/// <summary>Gets the number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> when <see cref="System.IO.Pipelines.PipeWriter.FlushAsync(System.Threading.CancellationToken)" /> stops blocking.</summary> 97/// <value>The number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> when <see cref="System.IO.Pipelines.PipeWriter.FlushAsync(System.Threading.CancellationToken)" /> stops blocking.</value>