PipeWriter

Internal\Http\HttpResponsePipeWriter.cs (1)

9internal sealed class HttpResponsePipeWriter : PipeWriter

Internal\Infrastructure\PipeWriterHelpers\ConcurrentPipeWriter.cs (1)

14internal sealed class ConcurrentPipeWriter : PipeWriter

Internal\Infrastructure\StatusCheckPipeWriter.cs (1)

12internal sealed class StatusCheckPipeWriter : PipeWriter

Internal\Infrastructure\ThrowingPipeWriter.cs (1)

8internal sealed class ThrowingPipeWriter : PipeWriter

Internal\Infrastructure\WrappingPipeWriter.cs (1)

8internal sealed class WrappingPipeWriter : PipeWriter

src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)

10internal sealed class CompletionPipeWriter : PipeWriter

ResponseBodyPipeWriter.cs (1)

9internal sealed class ResponseBodyPipeWriter : PipeWriter

src\runtime\src\libraries\Common\src\System\Text\Json\PooledByteBufferWriter.cs (1)

13internal sealed class PooledByteBufferWriter : PipeWriter, IDisposable

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

13private sealed class DefaultPipeWriter : PipeWriter, IValueTaskSource<FlushResult>

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

12internal sealed class StreamPipeWriter : PipeWriter

src\runtime\src\libraries\Common\src\System\Text\Json\PooledByteBufferWriter.cs (1)

13internal sealed class PooledByteBufferWriter : PipeWriter, IDisposable

BrowserLogsCdpConnectionTests.cs (1)

566private sealed class DuplexPipeStream(PipeReader reader, PipeWriter writer) : Stream

Features\IStatefulReconnectFeature.cs (2)

26/// Called when a connection reconnects. The new <see cref="PipeWriter"/> that application code should write to is passed in. 28public void OnReconnected(Func<PipeWriter, Task> notifyOnReconnect);

Internal\DefaultHttpResponse.cs (1)

122public override PipeWriter BodyWriter

StreamResponseBodyFeature.cs (3)

14private PipeWriter? _pipeWriter; 52public PipeWriter Writer 58_pipeWriter = PipeWriter.Create(Stream, new StreamPipeWriterOptions(leaveOpen: true));

Extensions\HttpResponseWritingExtensions.cs (2)

74var pipeWriter = response.BodyWriter; 100private static void WriteMultiSegmentEncoded(PipeWriter writer, string text, Encoding encoding, Span<byte> destination, int encodedLength, int minimumByteSize)

HttpResponse.cs (3)

55/// Gets the response body <see cref="PipeWriter"/> 57/// <value>The response body <see cref="PipeWriter"/>.</value> 58public virtual PipeWriter BodyWriter { get => throw new NotImplementedException(); }

Internal\HttpConnectionContext.cs (2)

75internal Func<PipeWriter, Task>? NotifyOnReconnect { get; set; } 1103public void OnReconnected(Func<PipeWriter, Task> notifyOnReconnect)

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

8public DuplexPipe(PipeReader reader, PipeWriter writer) 16public PipeWriter Output { get; }

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

14private readonly PipeWriter _pipeWriter; 16public PipeWriterStream(PipeWriter pipeWriter)

Internal\LongPollingTransport.cs (1)

34public PipeWriter Output => _transport!.Output;

Internal\ServerSentEventsTransport.cs (1)

35public PipeWriter Output => _transport!.Output;

Internal\WebSocketsTransport.cs (3)

47private Func<PipeWriter, Task>? _notifyOnReconnect; 53public PipeWriter Output => _transport!.Output; 56public void OnReconnected(Func<PipeWriter, Task> notifyOnReconnect)

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

8public DuplexPipe(PipeReader reader, PipeWriter writer) 16public PipeWriter Output { get; }

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

14private readonly PipeWriter _pipeWriter; 16public PipeWriterStream(PipeWriter pipeWriter)

HttpResponseJsonExtensions.cs (3)

188PipeWriter body, 285PipeWriter body, 331static async Task WriteAsJsonAsyncSlow(PipeWriter body, object? value, Type type, JsonSerializerContext context,

IHttpResponseBodyFeature.cs (2)

19/// A <see cref="PipeWriter"/> representing the response body, if any. 21PipeWriter Writer { get; }

ResponseBufferingStream.cs (3)

17private PipeWriter? _pipeAdapter; 89public PipeWriter Writer => _pipeAdapter ??= PipeWriter.Create(Stream, _pipeWriterOptions);

Formatters\SystemTextJsonOutputFormatter.cs (1)

90var responseWriter = httpContext.Response.BodyWriter;

Infrastructure\SystemTextJsonResultExecutor.cs (1)

68var responseWriter = response.BodyWriter;

IOutputCacheBufferStore.cs (1)

22ValueTask<bool> TryGetAsync(string key, PipeWriter destination, CancellationToken cancellationToken);

OutputCacheEntry.cs (1)

124public ValueTask CopyToAsync(PipeWriter destination, CancellationToken cancellationToken)

RecyclableReadOnlySequenceSegment.cs (1)

102public static async ValueTask CopyToAsync(ReadOnlySequence<byte> source, PipeWriter destination, CancellationToken cancellationToken)

RedisOutputCacheStore.cs (1)

206async ValueTask<bool> IOutputCacheBufferStore.TryGetAsync(string key, PipeWriter destination, CancellationToken cancellationToken)

OwinFeatureCollection.cs (3)

40private PipeWriter _responseBodyWrapper; 164PipeWriter IHttpResponseBodyFeature.Writer 170_responseBodyWrapper = PipeWriter.Create(Prop<Stream>(OwinConstants.ResponseBody), new StreamPipeWriterOptions(leaveOpen: true));

CacheEntry\CachedResponseBody.cs (2)

20public async Task CopyToAsync(PipeWriter destination, CancellationToken cancellationToken) 34private static void Copy(byte[] segment, PipeWriter destination)

ResponseCompressionBody.cs (3)

25private PipeWriter? _pipeAdapter; 86public PipeWriter Writer 92_pipeAdapter = PipeWriter.Create(Stream, new StreamPipeWriterOptions(leaveOpen: true));

RequestProcessing\RequestContext.FeatureCollection.cs (3)

68private PipeWriter? _pipeWriter; 469PipeWriter IHttpResponseBodyFeature.Writer 475_pipeWriter = PipeWriter.Create(_responseStream, new StreamPipeWriterOptions(leaveOpen: true));

Core\IISHttpContext.cs (1)

120public PipeWriter? ResponsePipeWrapper { get; set; }

Core\IISHttpContext.FeatureCollection.cs (2)

195PipeWriter IHttpResponseBodyFeature.Writer 201ResponsePipeWrapper = PipeWriter.Create(ResponseBody, new StreamPipeWriterOptions(leaveOpen: true));

Core\OutputProducer.cs (3)

87private Task FlushAsync(PipeWriter pipeWriter, CancellationToken cancellationToken) 99private Task FlushNowAsync(PipeWriter pipeWriter, CancellationToken cancellationToken) 123private async Task AwaitLastFlushAndThenFlushAsync(Task lastFlushTask, PipeWriter pipeWriter, CancellationToken cancellationToken)

src\aspnetcore\src\Shared\ServerInfrastructure\BufferExtensions.cs (7)

32public static void CopyTo(in this ReadOnlySequence<byte> buffer, PipeWriter pipeWriter) 44private static void CopyToMultiSegment(in ReadOnlySequence<byte> buffer, PipeWriter pipeWriter) 110internal static void WriteAscii(ref this BufferWriter<PipeWriter> buffer, string data) 132internal static void WriteNumeric(ref this BufferWriter<PipeWriter> bufferWriter, ulong number) 171private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 191internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 213private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

17/// two <see cref="PipeReader"/>s and two <see cref="PipeWriter"/>s - it is only how they are grouped that differs. 21public DuplexPipe(PipeReader reader, PipeWriter writer) 29public PipeWriter Output { get; }

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

20private readonly PipeWriter _output; 24public DuplexPipeStream(PipeReader input, PipeWriter output, bool throwOnCancelled = false)

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (2)

31Output = PipeWriter.Create(stream, writerOptions); 38public PipeWriter Output { get; }

Internal\Http\ChunkWriter.cs (2)

137internal static int WriteBeginChunkBytes(this ref BufferWriter<PipeWriter> start, int dataCount) 147internal static void WriteEndChunkBytes(this ref BufferWriter<PipeWriter> start)

Internal\Http\Http1ChunkedEncodingMessageBody.cs (2)

207private bool Read(ReadOnlySequence<byte> readableBuffer, PipeWriter writableBuffer, out SequencePosition consumed, out SequencePosition examined) 427private void ReadChunkedData(in ReadOnlySequence<byte> buffer, PipeWriter writableBuffer, out SequencePosition consumed, out SequencePosition examined)

Internal\Http\Http1Connection.cs (1)

1148var output = _context.Transport.Output;

Internal\Http\Http1OutputProducer.cs (14)

Internal\Http\HttpHeaders.Generated.cs (1)

14809internal void CopyToFast(ref BufferWriter<PipeWriter> output)

Internal\Http\HttpProtocol.cs (1)

292public PipeWriter ResponseBodyPipeWriter { get; set; } = default!;

Internal\Http\HttpProtocol.FeatureCollection.cs (1)

228PipeWriter IHttpResponseBodyFeature.Writer => ResponseBodyPipeWriter;

Internal\Http\HttpResponseHeaders.cs (3)

38internal void CopyTo(ref BufferWriter<PipeWriter> buffer) 57static void CopyExtraHeaders(ref BufferWriter<PipeWriter> buffer, Dictionary<string, StringValues> headers) 74static void CopyExtraHeadersCustomEncoding(ref BufferWriter<PipeWriter> buffer, Dictionary<string, StringValues> headers,

Internal\Http2\Http2Connection.cs (1)

1890private async Task CopyPipeAsync(PipeReader reader, PipeWriter writer)

Internal\Http2\Http2FrameWriter.cs (2)

110PipeWriter outputPipeWriter, 1029internal static void WriteHeader(Http2Frame frame, PipeWriter output)

Internal\Http3\Http3FrameWriter.cs (3)

45private PipeWriter _outputWriter = default!; 81public void Reset(PipeWriter output, string connectionId) 279internal static int WriteHeader(Http3FrameType frameType, long frameLength, PipeWriter output)

Internal\Http3\Http3OutputProducer.cs (1)

25private readonly PipeWriter _pipeWriter;

Internal\Infrastructure\BodyControl.cs (1)

58public (Stream request, Stream response, PipeReader reader, PipeWriter writer) Start(MessageBody body)

Internal\Infrastructure\PipeWriterHelpers\ConcurrentPipeWriter.cs (2)

25private readonly PipeWriter _innerPipeWriter; 53public ConcurrentPipeWriter(PipeWriter innerPipeWriter, MemoryPool<byte> pool, Lock sync)

Internal\Infrastructure\PipeWriterHelpers\TimingPipeFlusher.cs (2)

19private PipeWriter _writer = default!; 31public void Initialize(PipeWriter output)

Internal\Infrastructure\StatusCheckPipeWriter.cs (2)

14private readonly PipeWriter _inner; 17public StatusCheckPipeWriter(PipeWriter inner)

Internal\Infrastructure\WrappingPipeWriter.cs (3)

10private PipeWriter _inner; 12public WrappingPipeWriter(PipeWriter inner) 17public void SetInnerPipe(PipeWriter inner)

src\aspnetcore\src\Shared\ServerInfrastructure\BufferExtensions.cs (7)

32public static void CopyTo(in this ReadOnlySequence<byte> buffer, PipeWriter pipeWriter) 44private static void CopyToMultiSegment(in ReadOnlySequence<byte> buffer, PipeWriter pipeWriter) 110internal static void WriteAscii(ref this BufferWriter<PipeWriter> buffer, string data) 132internal static void WriteNumeric(ref this BufferWriter<PipeWriter> bufferWriter, ulong number) 171private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 191internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 213private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

17/// two <see cref="PipeReader"/>s and two <see cref="PipeWriter"/>s - it is only how they are grouped that differs. 21public DuplexPipe(PipeReader reader, PipeWriter writer) 29public PipeWriter Output { get; }

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

20private readonly PipeWriter _output; 24public DuplexPipeStream(PipeReader input, PipeWriter output, bool throwOnCancelled = false)

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (2)

31Output = PipeWriter.Create(stream, writerOptions); 38public PipeWriter Output { get; }

Internal\NamedPipeConnection.cs (2)

58public PipeWriter Input => Application.Output; 83var input = Input;

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

17/// two <see cref="PipeReader"/>s and two <see cref="PipeWriter"/>s - it is only how they are grouped that differs. 21public DuplexPipe(PipeReader reader, PipeWriter writer) 29public PipeWriter Output { get; }

Internal\QuicStreamContext.cs (2)

74private PipeWriter Input => Application.Output; 212var input = Input;

src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeWriter.cs (2)

12private readonly PipeWriter _inner; 18public CompletionPipeWriter(PipeWriter inner)

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

17/// two <see cref="PipeReader"/>s and two <see cref="PipeWriter"/>s - it is only how they are grouped that differs. 21public DuplexPipe(PipeReader reader, PipeWriter writer) 29public PipeWriter Output { get; }

Internal\SocketConnection.cs (1)

73public PipeWriter Input => Application.Output;

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

17/// two <see cref="PipeReader"/>s and two <see cref="PipeWriter"/>s - it is only how they are grouped that differs. 21public DuplexPipe(PipeReader reader, PipeWriter writer) 29public PipeWriter Output { get; }

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

42private PipeWriter _writer; 256internal async Task ResendAsync(PipeWriter writer)

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

14private readonly PipeWriter _pipeWriter; 16public PipeWriterStream(PipeWriter pipeWriter)

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

42private PipeWriter _writer; 256internal async Task ResendAsync(PipeWriter writer)

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

8public DuplexPipe(PipeReader reader, PipeWriter writer) 16public PipeWriter Output { get; }

Development\StaticAssetDevelopmentRuntimeHandler.cs (1)

162public PipeWriter Writer => _original.Writer;

HttpContextBuilder.cs (2)

28private Func<PipeWriter, Task>? _sendRequestStream; 68internal void SendRequestStream(Func<PipeWriter, Task> sendRequestStream)

ResponseFeature.cs (2)

68internal PipeWriter BodyWriter { get; set; } = default!; 70public PipeWriter Writer => BodyWriter;

FileBufferingWriteStream.cs (2)

217/// <param name="destination">The <see cref="PipeWriter" /> to drain buffered contents to.</param> 221public async Task DrainBufferAsync(PipeWriter destination, CancellationToken cancellationToken = default)

PagedByteBuffer.cs (1)

81public async Task MoveToAsync(PipeWriter writer, CancellationToken cancellationToken)

Workspace\Solution\Checksum.cs (1)

92public void WriteTo(PipeWriter pipeWriter)

Logging\Internal\HttpResponseBodyReader.cs (2)

132private static async ValueTask<string> BufferStreamAndWriteToPipeAsync(Stream stream, PipeWriter writer, int bufferSize, CancellationToken cancellationToken) 148private static async Task WriteStreamToPipeAsync(Stream stream, PipeWriter writer, CancellationToken cancellationToken)

System\IO\Pipelines\FlushResult.cs (10)

System\IO\Pipelines\IDuplexPipe.cs (2)

12/// <summary>Gets the <see cref="System.IO.Pipelines.PipeWriter" /> half of the duplex pipe.</summary> 13PipeWriter Output { get; }

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

15/// <summary>The default <see cref="System.IO.Pipelines.PipeWriter" /> and <see cref="System.IO.Pipelines.PipeReader" /> implementation.</summary> 1279/// <summary>Gets the <see cref="System.IO.Pipelines.PipeWriter" /> for this pipe.</summary> 1280/// <value>A <see cref="System.IO.Pipelines.PipeWriter" /> instance for this pipe.</value> 1281public PipeWriter Writer => _writer;

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

10/// <summary>The default <see cref="System.IO.Pipelines.PipeWriter" /> and <see cref="System.IO.Pipelines.PipeReader" /> implementation.</summary>

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

10/// <summary>The default <see cref="System.IO.Pipelines.PipeWriter" /> and <see cref="System.IO.Pipelines.PipeReader" /> implementation.</summary>

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

System\IO\Pipelines\PipeReader.cs (3)

141/// <summary>Registers a callback that executes when the <see cref="System.IO.Pipelines.PipeWriter" /> side of the pipe is completed.</summary> 173/// <summary>Asynchronously reads the bytes from the <see cref="System.IO.Pipelines.PipeReader" /> and writes them to the specified <see cref="System.IO.Pipelines.PipeWriter" />, using a specified buffer size and cancellation token.</summary> 177public virtual Task CopyToAsync(PipeWriter destination, CancellationToken cancellationToken = default)

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

8/// <summary>Abstraction for running <see cref="System.IO.Pipelines.PipeReader" /> and <see cref="System.IO.Pipelines.PipeWriter" /> callbacks and continuations.</summary>

System\IO\Pipelines\PipeWriter.cs (22)

System\IO\Pipelines\PipeWriterStream.cs (2)

12private readonly PipeWriter _pipeWriter; 14public PipeWriterStream(PipeWriter pipeWriter, bool leaveOpen)

System\IO\Pipelines\StreamPipeExtensions.cs (2)

12/// <summary>Asynchronously reads the bytes from the <see cref="System.IO.Stream" /> and writes them to the specified <see cref="System.IO.Pipelines.PipeWriter" />, using a cancellation token.</summary> 17public static Task CopyToAsync(this Stream source, PipeWriter destination, CancellationToken cancellationToken = default)

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

309public override async Task CopyToAsync(PipeWriter destination, CancellationToken cancellationToken = default)

System\IO\Pipelines\StreamPipeWriterOptions.cs (5)

8/// <summary>Represents a set of options for controlling the creation of the <see cref="System.IO.Pipelines.PipeWriter" />.</summary> 15/// <summary>Initializes a <see cref="System.IO.Pipelines.StreamPipeWriterOptions" /> instance, optionally specifying a memory pool, a minimum buffer size, and whether the underlying stream should be left open after the <see cref="System.IO.Pipelines.PipeWriter" /> completes.</summary> 18/// <param name="leaveOpen"><see langword="true" /> to leave the underlying stream open after the <see cref="System.IO.Pipelines.PipeWriter" /> completes; <see langword="false" /> to close it. The default is <see langword="false" />.</param> 39/// <summary>Gets the value that indicates if the underlying stream should be left open after the <see cref="System.IO.Pipelines.PipeWriter" /> completes.</summary> 40/// <value><see langword="true" /> if the underlying stream should be left open after the <see cref="System.IO.Pipelines.PipeWriter" /> completes; otherwise, <see langword="false" />.</value>

System\Text\Json\Serialization\JsonSerializer.Write.Pipe.cs (22)

System\Text\Json\Serialization\Metadata\JsonTypeInfo.cs (2)

1477internal abstract Task<FlushResult> SerializeAsObjectAsync(PipeWriter pipeWriter, object? rootValue, int flushThreshold, CancellationToken cancellationToken, Utf8JsonWriter? jsonLineWriter = null); 1479internal abstract Task SerializeAsObjectAsync(PipeWriter utf8Json, object? rootValue, CancellationToken cancellationToken);

System\Text\Json\Serialization\Metadata\JsonTypeInfoOfT.WriteHelpers.cs (5)

74internal Task SerializeAsync(PipeWriter utf8Json, 86PipeWriter pipeWriter, 270static void WriteJsonLineTerminator(PipeWriter pipeWriter) 371internal sealed override Task<FlushResult> SerializeAsObjectAsync(PipeWriter pipeWriter, object? rootValue, int flushThreshold, CancellationToken cancellationToken, Utf8JsonWriter? jsonLineWriter = null) 377internal sealed override Task SerializeAsObjectAsync(PipeWriter utf8Json, object? rootValue, CancellationToken cancellationToken)

System\Text\Json\Serialization\WriteStack.cs (1)

86public PipeWriter? PipeWriter;

System\Text\Json\ThrowHelper.Serialization.cs (1)

1160public static void ThrowInvalidOperationException_PipeWriterDoesNotImplementUnflushedBytes(PipeWriter pipeWriter)