PipeWriter

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

10internal sealed class CompletionPipeWriter : PipeWriter

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

39private class PassThroughPipeWriter : PipeWriter

EndToEndBenchmarks.cs (1)

265internal sealed class NullPipeWriter : PipeWriter, IDisposable

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

ConcurrentPipeWriterTests.cs (1)

413private class MockPipeWriter : PipeWriter

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

39private class PassThroughPipeWriter : PipeWriter

Mocks\NullPipeWriter.cs (1)

11internal sealed class NullPipeWriter : PipeWriter

ResponseHeadersWritingBenchmark.cs (1)

195public class Writer : PipeWriter

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

10internal sealed class CompletionPipeWriter : PipeWriter

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

10internal sealed class CompletionPipeWriter : PipeWriter

Shared\TestPipeWriter.cs (1)

8public class TestPipeWriter : PipeWriter

ResponseBodyPipeWriter.cs (1)

9internal sealed class ResponseBodyPipeWriter : PipeWriter

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

15internal sealed class PooledByteBufferWriter : PipeWriter, IDisposable

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

39private class PassThroughPipeWriter : PipeWriter

src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)

134private class MockPipeWriter : PipeWriter

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\libraries\Common\src\System\Text\Json\PooledByteBufferWriter.cs (1)

15internal sealed class PooledByteBufferWriter : PipeWriter, IDisposable

RawSample.cs (1)

101private static async Task SendLoop(TextReader input, PipeWriter output)

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

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

src\Shared\Http2cat\Http2Utilities.cs (2)

247internal static void WriteHeader(Http2Frame frame, PipeWriter output) 396public static async Task FlushAsync(PipeWriter writableBuffer)

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 unsafe void WriteNumeric(ref this BufferWriter<PipeWriter> buffer, ulong number) 182private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 202internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 224private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

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

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

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

src\Shared\Http2cat\Http2Utilities.cs (2)

247internal static void WriteHeader(Http2Frame frame, PipeWriter output) 396public static async Task FlushAsync(PipeWriter writableBuffer)

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 unsafe void WriteNumeric(ref this BufferWriter<PipeWriter> buffer, ulong number) 182private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 202internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 224private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

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

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

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

src\Shared\Http2cat\Http2Utilities.cs (2)

247internal static void WriteHeader(Http2Frame frame, PipeWriter output) 396public static async Task FlushAsync(PipeWriter writableBuffer)

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 unsafe void WriteNumeric(ref this BufferWriter<PipeWriter> buffer, ulong number) 182private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 202internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 224private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

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

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

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

src\Shared\Http2cat\Http2Utilities.cs (2)

247internal static void WriteHeader(Http2Frame frame, PipeWriter output) 396public static async Task FlushAsync(PipeWriter writableBuffer)

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 unsafe void WriteNumeric(ref this BufferWriter<PipeWriter> buffer, ulong number) 182private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 202internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 224private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

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

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

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

src\Shared\Http2cat\Http2Utilities.cs (2)

247internal static void WriteHeader(Http2Frame frame, PipeWriter output) 396public static async Task FlushAsync(PipeWriter writableBuffer)

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 unsafe void WriteNumeric(ref this BufferWriter<PipeWriter> buffer, ulong number) 182private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 202internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 224private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

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

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

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

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 unsafe void WriteNumeric(ref this BufferWriter<PipeWriter> buffer, ulong number) 182private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 202internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 224private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

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

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

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

src\Shared\Http2cat\Http2Utilities.cs (2)

247internal static void WriteHeader(Http2Frame frame, PipeWriter output) 396public static async Task FlushAsync(PipeWriter writableBuffer)

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 unsafe void WriteNumeric(ref this BufferWriter<PipeWriter> buffer, ulong number) 182private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 202internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 224private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

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

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

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

Http2\Http2TestBase.cs (1)

760protected static async Task FlushAsync(PipeWriter writableBuffer)

RequestTests.cs (1)

59PipeWriter bodyPipe = null;

ResponseTests.cs (3)

3198void WriteStringWithoutFlushing(PipeWriter writer, string content) 4266var BodyWriter1 = httpContext.Response.BodyWriter; 4269var BodyWriter2 = httpContext.Response.BodyWriter;

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

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

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

509protected static Task FlushAsync(PipeWriter writableBuffer) 867void WriteSpan(PipeWriter pw)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (3)

37public PipeWriter Output { get; } 41private readonly PipeWriter _output; 43public PassThroughPipeWriter(PipeWriter output)

src\Servers\Kestrel\shared\test\PipeWriterHttp2FrameExtensions.cs (5)

19public static void WriteSettings(this PipeWriter writer, Http2PeerSettings clientSettings) 31public static void WriteStartStream(this PipeWriter writer, int streamId, DynamicHPackEncoder hpackEncoder, Http2HeadersEnumerator headers, byte[] headerEncodingBuffer, bool endStream, Http2Frame frame = null) 70public static void WriteStartStream(this PipeWriter writer, int streamId, Span<byte> headerData, bool endStream, Http2Frame frame = null) 86public static void WriteData(this PipeWriter writer, int streamId, Memory<byte> data, bool endStream, Http2Frame frame = null) 97public static void WriteWindowUpdateAsync(this PipeWriter writer, int streamId, int sizeIncrement, Http2Frame frame = null)

TestTransport\InMemoryTransportConnection.cs (2)

41public PipeWriter Input => Application.Output; 113public PipeWriter Output { get; }

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)

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

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

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

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\SignalR\common\Shared\DuplexPipe.cs (2)

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

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

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

HttpConnectionDispatcherTests.cs (2)

3988private PipeWriter _writer; 4032private Task NotifyReconnect(PipeWriter writer)

RequestDelegateFactoryTests.cs (2)

3736public PipeWriter Writer 3741return PipeWriter.Create(Stream.Null);

SendFileResponseExtensionsTests.cs (1)

111public PipeWriter Writer => throw new System.NotImplementedException();

IHttpResponseBodyFeature.cs (2)

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

src\Shared\ResultsTests\PhysicalFileResultTestBase.cs (1)

431public PipeWriter Writer => throw new NotImplementedException();

src\Shared\ResultsTests\VirtualFileResultTestBase.cs (1)

534public PipeWriter Writer => throw new NotImplementedException();

Internal\DefaultHttpResponseTests.cs (1)

63var bodyPipe = response.Response.BodyWriter;

ResponseBufferingStream.cs (3)

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

src\Shared\ResultsTests\PhysicalFileResultTestBase.cs (1)

431public PipeWriter Writer => throw new NotImplementedException();

src\Shared\ResultsTests\VirtualFileResultTestBase.cs (1)

534public PipeWriter Writer => throw new NotImplementedException();

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)

EndToEndBenchmarks.cs (3)

90static Task WriteInRandomChunks(ReadOnlyMemory<byte> source, PipeWriter destination, CancellationToken cancellationToken) 156var pipe = PipeWriter.Create(oc, new StreamPipeWriterOptions(leaveOpen: true));

RedisOutputCacheStore.cs (1)

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

CachedResponseBodyTests.cs (1)

90static async Task CopyDataAsync(ReadOnlySequence<byte> body, PipeWriter writer, CancellationToken cancellationToken)

TestUtils.cs (1)

372async 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)

ResponseCachingBenchmark.cs (2)

114public PipeResponseBodyFeature(PipeWriter pipeWriter) 121public PipeWriter Writer { get; }

CachedResponseBodyTests.cs (1)

95static async Task CopyDataAsync(CachedResponseBody body, PipeWriter writer, CancellationToken cancellationToken)

ResponseCompressionBody.cs (3)

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

ResponseCompressionMiddlewareTest.cs (1)

1357public PipeWriter Writer => InnerFeature.Writer;

RequestProcessing\RequestContext.FeatureCollection.cs (3)

63private PipeWriter? _pipeWriter; 415PipeWriter IHttpResponseBodyFeature.Writer 421_pipeWriter = PipeWriter.Create(_responseStream, new StreamPipeWriterOptions(leaveOpen: true));

ResponseBodyTests.cs (2)

75var writer = httpContext.Response.BodyWriter; 95var writer = httpContext.Response.BodyWriter;

src\Shared\Http2cat\Http2Utilities.cs (2)

247internal static void WriteHeader(Http2Frame frame, PipeWriter output) 396public static async Task FlushAsync(PipeWriter writableBuffer)

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 unsafe void WriteNumeric(ref this BufferWriter<PipeWriter> buffer, ulong number) 182private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 202internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 224private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

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

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

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

Core\IISHttpContext.cs (1)

116public PipeWriter? ResponsePipeWrapper { get; set; }

Core\IISHttpContext.FeatureCollection.cs (2)

191PipeWriter IHttpResponseBodyFeature.Writer 197ResponsePipeWrapper = 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\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 unsafe void WriteNumeric(ref this BufferWriter<PipeWriter> buffer, ulong number) 182private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 202internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 224private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

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

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

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

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)

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

Internal\Http\Http1OutputProducer.cs (14)

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

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

Internal\Http\HttpProtocol.cs (1)

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

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

Internal\Http2\Http2FrameWriter.cs (2)

95PipeWriter outputPipeWriter, 1000internal 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, object 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\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 unsafe void WriteNumeric(ref this BufferWriter<PipeWriter> buffer, ulong number) 182private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 202internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 224private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

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

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

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

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

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

BufferWriterTests.cs (22)

Http1\Http1ConnectionTests.cs (2)

715var writer = _application.Output; 729var writer = _application.Output;

HttpConnectionTests.cs (1)

28transport: new DuplexPipe(Mock.Of<PipeReader>(), Mock.Of<PipeWriter>()));

PipelineExtensionTests.cs (12)

40var writerBuffer = _pipe.Writer; 41var writer = new BufferWriter<PipeWriter>(writerBuffer); 58var writerBuffer = _pipe.Writer; 59var writer = new BufferWriter<PipeWriter>(writerBuffer); 89var pipeWriter = _pipe.Writer; 90var writer = new BufferWriter<PipeWriter>(pipeWriter); 119var writerBuffer = _pipe.Writer; 120var writer = new BufferWriter<PipeWriter>(writerBuffer); 133var writerBuffer = _pipe.Writer; 134var writer = new BufferWriter<PipeWriter>(writerBuffer); 162var writerBuffer = _pipe.Writer; 163var writer = new BufferWriter<PipeWriter>(writerBuffer);

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (3)

37public PipeWriter Output { get; } 41private readonly PipeWriter _output; 43public PassThroughPipeWriter(PipeWriter output)

src\Servers\Kestrel\shared\test\PipeWriterHttp2FrameExtensions.cs (5)

19public static void WriteSettings(this PipeWriter writer, Http2PeerSettings clientSettings) 31public static void WriteStartStream(this PipeWriter writer, int streamId, DynamicHPackEncoder hpackEncoder, Http2HeadersEnumerator headers, byte[] headerEncodingBuffer, bool endStream, Http2Frame frame = null) 70public static void WriteStartStream(this PipeWriter writer, int streamId, Span<byte> headerData, bool endStream, Http2Frame frame = null) 86public static void WriteData(this PipeWriter writer, int streamId, Memory<byte> data, bool endStream, Http2Frame frame = null) 97public static void WriteWindowUpdateAsync(this PipeWriter writer, int streamId, int sizeIncrement, Http2Frame frame = null)

ChunkWriterBenchmark.cs (2)

17private PipeWriter _writer; 46var writer = new BufferWriter<PipeWriter>(_writer);

InMemoryTransportBenchmark.cs (1)

182public PipeWriter Input => Application.Output;

Mocks\MockDuplexPipe.cs (2)

10public MockDuplexPipe(PipeReader input, PipeWriter output) 17public PipeWriter Output { get; }

ResponseHeadersWritingBenchmark.cs (6)

75var writer = new BufferWriter<PipeWriter>(_writer); 88var writer = new BufferWriter<PipeWriter>(_writer); 105var writer = new BufferWriter<PipeWriter>(_writer); 139var writer = new BufferWriter<PipeWriter>(_writer); 154var writer = new BufferWriter<PipeWriter>(_writer); 169var writer = new BufferWriter<PipeWriter>(_writer);

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

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

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

509protected static Task FlushAsync(PipeWriter writableBuffer) 867void WriteSpan(PipeWriter pw)

src\Servers\Kestrel\shared\test\PipeWriterHttp2FrameExtensions.cs (5)

19public static void WriteSettings(this PipeWriter writer, Http2PeerSettings clientSettings) 31public static void WriteStartStream(this PipeWriter writer, int streamId, DynamicHPackEncoder hpackEncoder, Http2HeadersEnumerator headers, byte[] headerEncodingBuffer, bool endStream, Http2Frame frame = null) 70public static void WriteStartStream(this PipeWriter writer, int streamId, Span<byte> headerData, bool endStream, Http2Frame frame = null) 86public static void WriteData(this PipeWriter writer, int streamId, Memory<byte> data, bool endStream, Http2Frame frame = null) 97public static void WriteWindowUpdateAsync(this PipeWriter writer, int streamId, int sizeIncrement, Http2Frame frame = null)

Internal\NamedPipeConnection.cs (2)

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

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

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

Internal\QuicStreamContext.cs (2)

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

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

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

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

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

Internal\SocketConnection.cs (1)

71public PipeWriter Input => Application.Output;

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

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

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 unsafe void WriteNumeric(ref this BufferWriter<PipeWriter> buffer, ulong number) 182private static void WriteNumericMultiWrite(ref this BufferWriter<PipeWriter> buffer, ulong number) 202internal static void WriteEncoded(ref this BufferWriter<PipeWriter> buffer, string data, Encoding encoding) 224private static void WriteEncodedMultiWrite(ref this BufferWriter<PipeWriter> buffer, string data, int encodedLength, Encoding encoding)

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

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

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

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

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

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

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

41private PipeWriter _writer; 248internal async Task ResendAsync(PipeWriter writer)

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

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

HubConnectionTests.cs (1)

1040public void OnReconnected(Func<PipeWriter, Task> notifyOnReconnected) { }

TestTransport.cs (1)

27public PipeWriter Output => _transport.Output;

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

41private PipeWriter _writer; 248internal async Task ResendAsync(PipeWriter writer)

Shared\TestDuplexPipe.cs (1)

14public PipeWriter Output { get; }

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

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

EndToEndTests.cs (1)

709public PipeWriter Output => _transport.Output;

HubConnectionHandlerTests.cs (5)

3001public PipeWriter Output => _originalDuplexPipe.Output; 5229public void OnReconnected(Func<PipeWriter, Task> notifyOnReconnect) { } 5337private Func<PipeWriter, Task> _notifyOnReconnect; 5341public Task NotifyOnReconnect(PipeWriter writer) 5347public void OnReconnected(Func<PipeWriter, Task> notifyOnReconnect)

Internal\MessageBufferTests.cs (2)

508public DuplexPipe(PipeReader reader, PipeWriter writer) 516public PipeWriter Output { get; }

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

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

Development\StaticAssetDevelopmentRuntimeHandler.cs (1)

82public 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;

ResponseBodyTests.cs (2)

21var writer = httpContext.Response.BodyWriter; 39var writer = httpContext.Response.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)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (3)

37public PipeWriter Output { get; } 41private readonly PipeWriter _output; 43public PassThroughPipeWriter(PipeWriter output)

src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)

92public PipeWriter Output => new MockPipeWriter(this);

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> 1171/// <summary>Gets the <see cref="System.IO.Pipelines.PipeWriter" /> for this pipe.</summary> 1172/// <value>A <see cref="System.IO.Pipelines.PipeWriter" /> instance for this pipe.</value> 1173public 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)

142/// <summary>Registers a callback that executes when the <see cref="System.IO.Pipelines.PipeWriter" /> side of the pipe is completed.</summary> 174/// <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> 178public 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 (20)

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)

311public 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 (15)

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

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

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

73internal Task SerializeAsync(PipeWriter utf8Json, 85PipeWriter pipeWriter, 339internal sealed override Task SerializeAsObjectAsync(PipeWriter pipeWriter, object? rootValue, int flushThreshold, CancellationToken cancellationToken) 345internal sealed override Task SerializeAsObjectAsync(PipeWriter utf8Json, object? rootValue, CancellationToken cancellationToken)

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

92public PipeWriter? PipeWriter;

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

935public static void ThrowInvalidOperationException_PipeWriterDoesNotImplementUnflushedBytes(PipeWriter pipeWriter)

Program.cs (1)

116var outputPipe = stream.Transport.Output;