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)

128private 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)

254internal static void WriteHeader(Http2Frame frame, PipeWriter output) 403public 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 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\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)

254internal static void WriteHeader(Http2Frame frame, PipeWriter output) 403public 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 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\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)

254internal static void WriteHeader(Http2Frame frame, PipeWriter output) 403public 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 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\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)

254internal static void WriteHeader(Http2Frame frame, PipeWriter output) 403public 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 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\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)

254internal static void WriteHeader(Http2Frame frame, PipeWriter output) 403public 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 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\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 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\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)

254internal static void WriteHeader(Http2Frame frame, PipeWriter output) 403public 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 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\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)

788protected static async Task FlushAsync(PipeWriter writableBuffer)

RequestTests.cs (1)

60PipeWriter bodyPipe = null;

ResponseTests.cs (3)

3238void WriteStringWithoutFlushing(PipeWriter writer, string content) 4306var BodyWriter1 = httpContext.Response.BodyWriter; 4309var 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)

514protected static Task FlushAsync(PipeWriter writableBuffer) 872void 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)

HttpResponseJsonExtensions.cs (3)

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

RequestDelegateFactoryTests.cs (2)

3742public PipeWriter Writer 3747return 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);

Formatters\SystemTextJsonOutputFormatter.cs (1)

90var responseWriter = httpContext.Response.BodyWriter;

Infrastructure\SystemTextJsonResultExecutor.cs (1)

68var responseWriter = response.BodyWriter;

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)

373async 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; 432PipeWriter IHttpResponseBodyFeature.Writer 438_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)

254internal static void WriteHeader(Http2Frame frame, PipeWriter output) 403public 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 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\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)

117public PipeWriter? ResponsePipeWrapper { get; set; }

Core\IISHttpContext.FeatureCollection.cs (2)

192PipeWriter IHttpResponseBodyFeature.Writer 198ResponsePipeWrapper = 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 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\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\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)

202private bool Read(ReadOnlySequence<byte> readableBuffer, PipeWriter writableBuffer, out SequencePosition consumed, out SequencePosition examined) 400private 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 void CopyToFast(ref BufferWriter<PipeWriter> output)

Internal\Http\HttpProtocol.cs (1)

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

1850private 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\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\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\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)

718var writer = _application.Output; 732var writer = _application.Output;

HttpConnectionTests.cs (1)

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

PipelineExtensionTests.cs (14)

39var writerBuffer = _pipe.Writer; 40var writer = new BufferWriter<PipeWriter>(writerBuffer); 56var writerBuffer = _pipe.Writer; 57var writer = new BufferWriter<PipeWriter>(writerBuffer); 76var writerBuffer = _pipe.Writer; 77var writer = new BufferWriter<PipeWriter>(writerBuffer); 107var pipeWriter = _pipe.Writer; 108var writer = new BufferWriter<PipeWriter>(pipeWriter); 137var writerBuffer = _pipe.Writer; 138var writer = new BufferWriter<PipeWriter>(writerBuffer); 151var writerBuffer = _pipe.Writer; 152var writer = new BufferWriter<PipeWriter>(writerBuffer); 180var writerBuffer = _pipe.Writer; 181var 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)

514protected static Task FlushAsync(PipeWriter writableBuffer) 872void 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 (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; 210var input = Input;

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

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

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)

71public PipeWriter Input => Application.Output;

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\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\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\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)

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

ISolutionAssetProvider.cs (2)

23/// cref="PipeWriter.Complete"/> on it (in the event of failure or success). Failing to do so will lead to hangs on 29PipeWriter pipeWriter, Checksum solutionChecksum, AssetPath assetPath, ReadOnlyMemory<Checksum> checksums, CancellationToken cancellationToken);

RemoteCallback.cs (4)

96/// cref="PipeWriter.Complete"/> the <see cref="PipeWriter"/>. If it does not then reading will hang</param> 101Func<T, PipeWriter, CancellationToken, ValueTask> invocation, 130async Task WriteAsync(T service, PipeWriter pipeWriter)

RemoteHostAssetWriter.cs (2)

54PipeWriter pipeWriter, Scope scope, AssetPath assetPath, ReadOnlyMemory<Checksum> checksums, ISerializerService serializer) 65private readonly PipeWriter _pipeWriter = pipeWriter;

SolutionAssetProvider.cs (2)

28PipeWriter pipeWriter, 44async ValueTask WriteAssetsSuppressedFlowAsync(PipeWriter pipeWriter, Checksum solutionChecksum, AssetPath assetPath, ReadOnlyMemory<Checksum> checksums, CancellationToken cancellationToken)

Workspace\Solution\Checksum.cs (1)

92public void WriteTo(PipeWriter pipeWriter)

Remote\ServiceDescriptorTests.cs (1)

137type != typeof(PipeWriter))

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)

86public 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> 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 (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)

1054internal abstract Task SerializeAsObjectAsync(PipeWriter pipeWriter, object? rootValue, int flushThreshold, CancellationToken cancellationToken); 1056internal 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, 334internal sealed override Task SerializeAsObjectAsync(PipeWriter pipeWriter, object? rootValue, int flushThreshold, CancellationToken cancellationToken) 340internal 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)

943public static void ThrowInvalidOperationException_PipeWriterDoesNotImplementUnflushedBytes(PipeWriter pipeWriter)

Program.cs (1)

116var outputPipe = stream.Transport.Output;