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

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)

69internal Func<PipeWriter, Task>? NotifyOnReconnect { get; set; } 860public 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)

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

Internal\Http\Http1Connection.cs (1)

1118var 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)

72public 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)

130private static async ValueTask<string> BufferStreamAndWriteToPipeAsync(Stream stream, PipeWriter writer, int bufferSize, CancellationToken cancellationToken) 146private 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)

14/// <summary>The default <see cref="System.IO.Pipelines.PipeWriter" /> and <see cref="System.IO.Pipelines.PipeReader" /> implementation.</summary> 1168/// <summary>Gets the <see cref="System.IO.Pipelines.PipeWriter" /> for this pipe.</summary> 1169/// <value>A <see cref="System.IO.Pipelines.PipeWriter" /> instance for this pipe.</value> 1170public 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)

1517internal abstract Task SerializeAsObjectAsync(PipeWriter pipeWriter, object? rootValue, int flushThreshold, CancellationToken cancellationToken); 1519internal abstract Task SerializeAsObjectAsync(PipeWriter utf8Json, object? rootValue, CancellationToken cancellationToken);

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

74internal Task SerializeAsync(PipeWriter utf8Json, 86PipeWriter pipeWriter, 337internal sealed override Task SerializeAsObjectAsync(PipeWriter pipeWriter, object? rootValue, int flushThreshold, CancellationToken cancellationToken) 343internal 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)

1103public static void ThrowInvalidOperationException_PipeWriterDoesNotImplementUnflushedBytes(PipeWriter pipeWriter)