PipeReader

Http3\WebTransport\WebTransportTestUtilities.cs (1)

161class StreamReader : PipeReader

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

10internal sealed class CompletionPipeReader : PipeReader

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

61private class PassThroughPipeReader : PipeReader

TestTransport\InMemoryTransportConnection.cs (1)

113private class ObservablePipeReader : PipeReader

Internal\Http\HttpRequestPipeReader.cs (1)

13internal sealed class HttpRequestPipeReader : PipeReader

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

61private class PassThroughPipeReader : PipeReader

TestHelpers\ObservablePipeReader.cs (1)

11internal class ObservablePipeReader : PipeReader

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

10internal sealed class CompletionPipeReader : PipeReader

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

10internal sealed class CompletionPipeReader : PipeReader

Shared\TestPipeReader.cs (1)

8public class TestPipeReader : PipeReader

HubConnectionHandlerTests.cs (1)

2932internal class PipeReaderWrapper : PipeReader

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

61private class PassThroughPipeReader : PipeReader

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

88private class MockPipeReader : PipeReader

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

13private sealed class DefaultPipeReader : PipeReader, IValueTaskSource<ReadResult>

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

10internal sealed class SequencePipeReader : PipeReader

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

12internal sealed class StreamPipeReader : PipeReader

Dcp\DcpHost.cs (2)

270var reader = PipeReader.Create(stream);

RawSample.cs (1)

75private static async Task ReceiveLoop(TextWriter output, PipeReader input)

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

8public DuplexPipe(PipeReader reader, PipeWriter writer) 14public PipeReader Input { get; }

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

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

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

30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }

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

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

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

30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }

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

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

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

30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }

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

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

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

30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }

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

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

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

30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }

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

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

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

30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }

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

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

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

30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }

Http2\PipeReaderFactory.cs (2)

15private static readonly Action<object> _cancelReader = state => ((PipeReader)state).CancelPendingRead(); 17public static PipeReader CreateFromStream(PipeOptions options, Stream stream, CancellationToken cancellationToken)

Http2\TlsTests.cs (3)

74var reader = PipeReaderFactory.CreateFromStream(PipeOptions.Default, sslStream, CancellationToken.None); 83private async Task WaitForConnectionErrorAsync(PipeReader reader, bool ignoreNonGoAwayFrames, int expectedLastStreamId, Http2ErrorCode expectedErrorCode) 103private async Task<Http2Frame> ReceiveFrameAsync(PipeReader reader)

Http3\Http3StreamTests.cs (1)

3320private async Task WriteOneByteAtATime(PipeReader reader, PipeWriter writer)

RequestTests.cs (1)

1163static async Task<ReadResult> ReadAtLeastAsync(PipeReader reader, int numBytes)

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

12private readonly PipeReader _inner; 18public CompletionPipeReader(PipeReader inner)

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

35public PipeReader Input { get; } 63private readonly PipeReader _input; 65public PassThroughPipeReader(PipeReader input)

TestTransport\InMemoryTransportConnection.cs (4)

43public PipeReader Output => Application.Input; 109public PipeReader Input { get; } 115private readonly PipeReader _reader; 120public ObservablePipeReader(PipeReader reader)

HttpClientHttp2InteropTests.cs (2)

269var reader = context.Request.BodyReader; 328var reader = context.Request.BodyReader;

Verifiers\CSharpAnalyzerVerifier.cs (1)

65TrimAssemblyExtension(typeof(System.IO.Pipelines.PipeReader).Assembly.Location),

Circuits\RemoteJSDataStream.cs (1)

86public PipeReader PipeReader { get; }

ServerStreamingServerCallHandlerTests.cs (1)

262public async Task<string?> ReadLineAsync(PipeReader pipeReader)

Features\RequestBodyPipeFeature.cs (4)

13private PipeReader? _internalPipeReader; 31public PipeReader Reader 39_internalPipeReader = PipeReader.Create(_context.Request.Body, _defaultReaderOptions); 43((PipeReader)self).Complete();

Internal\DefaultHttpRequest.cs (1)

172public override PipeReader BodyReader

HttpRequest.cs (3)

114/// Gets the request body <see cref="PipeReader"/>. 116/// <value>The request body <see cref="PipeReader"/>.</value> 117public virtual PipeReader BodyReader { get => throw new NotImplementedException(); }

Internal\Transports\LongPollingServerTransport.cs (3)

12private readonly PipeReader _application; 17public LongPollingServerTransport(CancellationToken timeoutToken, PipeReader application, ILoggerFactory loggerFactory) 21public LongPollingServerTransport(CancellationToken timeoutToken, PipeReader application, ILoggerFactory loggerFactory, HttpConnectionContext? connection)

Internal\Transports\ServerSentEventsServerTransport.cs (3)

12private readonly PipeReader _application; 17public ServerSentEventsServerTransport(PipeReader application, string connectionId, ILoggerFactory loggerFactory) 21public ServerSentEventsServerTransport(PipeReader application, string connectionId, HttpConnectionContext? connection, ILoggerFactory loggerFactory)

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

8public DuplexPipe(PipeReader reader, PipeWriter writer) 14public PipeReader Input { get; }

Internal\LongPollingTransport.cs (1)

32public PipeReader Input => _transport!.Input;

Internal\ServerSentEventsTransport.cs (1)

33public PipeReader Input => _transport!.Input;

Internal\WebSocketsTransport.cs (1)

51public PipeReader Input => _transport!.Input;

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

8public DuplexPipe(PipeReader reader, PipeWriter writer) 14public PipeReader Input { get; }

RequestDelegateFactory.cs (2)

757else if (parameter.ParameterType == typeof(PipeReader)) 871else if (parameter.ParameterType == typeof(PipeReader))

RequestDelegateGenerator\RequestDelegateCreationTestBase.cs (2)

499public PipeRequestBodyFeature(PipeReader pipeReader) 503public PipeReader Reader { get; set; }

RequestDelegateGenerator\RequestDelegateCreationTests.JsonBody.cs (4)

314var pipeReader = PipeReader.Create(new MemoryStream(requestBodyBytes)); 355var pipeReader = PipeReader.Create(new MemoryStream(requestBodyBytes));

IRequestBodyPipeFeature.cs (3)

9/// Represents the HTTP request body as a <see cref="PipeReader"/>. 14/// Gets a <see cref="PipeReader"/> representing the request body, if any. 16PipeReader Reader { get; }

src\Http\Http.Extensions\test\RequestDelegateGenerator\RequestDelegateCreationTestBase.cs (2)

499public PipeRequestBodyFeature(PipeReader pipeReader) 503public PipeReader Reader { get; set; }

Results.cs (3)

414/// Writes the contents of specified <see cref="System.IO.Pipelines.PipeReader"/> to the response. 420/// <param name="pipeReader">The <see cref="System.IO.Pipelines.PipeReader"/> to write to the response.</param> 433PipeReader pipeReader,

TypedResults.cs (3)

424/// Writes the contents of the specified <see cref="System.IO.Pipelines.PipeReader"/> to the response. 433/// <param name="pipeReader">The <see cref="System.IO.Pipelines.PipeReader"/> to write to the response.</param> 443PipeReader pipeReader,

ResultsTests.cs (2)

3021 => Results.Stream(PipeReader.Create(stream), contentType, fileDownloadName, lastModified, entityTag, enableRangeProcessing), 368Assert.Throws<ArgumentNullException>("pipeReader", () => Results.Stream(default(PipeReader)));

TypedResultsTests.cs (2)

342Assert.Throws<ArgumentNullException>("pipeReader", () => TypedResults.Stream(default(PipeReader))); 3861 => TypedResults.Stream(PipeReader.Create(stream), contentType, fileDownloadName, lastModified, entityTag, enableRangeProcessing),

Features\FormFeatureTests.cs (1)

120public PipeReader Reader { get; set; }

Features\RequestBodyPipeFeatureTests.cs (2)

22var pipeBody = feature.Reader; 33var _ = feature.Reader;

Internal\DefaultHttpRequestTests.cs (1)

246var bodyPipe = context.Request.BodyReader;

Extensions\JsonTypeInfoExtensions.cs (1)

35[typeof(PipeReader)] = "PipeReader",

Services\OpenApiDocumentService.cs (1)

724if (bodyParameter.Type == typeof(Stream) || bodyParameter.Type == typeof(PipeReader))

Services\Schemas\OpenApiSchemaService.cs (1)

63if (type == typeof(IFormFile) || type == typeof(Stream) || type == typeof(PipeReader))

Extensions\JsonTypeInfoExtensionsTests.cs (1)

65[typeof(PipeReader), "PipeReader"],

Services\OpenApiDocumentService\OpenApiDocumentServiceTests.RequestBody.cs (2)

1090builder.MapGet("/pipereader", (PipeReader pipeReader) => { }); 1135private void ActionWithPipeReader(PipeReader pipeReader) { }

Services\OpenApiSchemaService\OpenApiSchemaService.RequestBodySchemas.cs (1)

202builder.MapPost("/pipereader", ([FromBody] PipeReader stream) => { });

CachedResponseBodyTests.cs (1)

99static async Task ReceiveDataAsync(PipeReader reader, List<byte[]> receivedSegments, CancellationToken cancellationToken)

ResponseCachingBenchmark.cs (1)

94private async ValueTask ConsumeAsync(PipeReader reader, CancellationToken cancellationToken)

CachedResponseBodyTests.cs (1)

103static async Task ReceiveDataAsync(PipeReader reader, List<byte[]> receivedSegments, CancellationToken cancellationToken)

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

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

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

30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }

Core\OutputProducer.cs (1)

31public PipeReader Reader => _pipe.Reader;

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) 27public PipeReader Input { get; }

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

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

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

30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }

Internal\Http\Http1Connection.cs (1)

74public PipeReader Input { get; }

Internal\Http\HttpProtocol.cs (1)

237public PipeReader RequestBodyPipeReader { get; set; } = default!;

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

88PipeReader IRequestBodyPipeFeature.Reader 95RequestBodyPipeReader = PipeReader.Create(RequestBody, new StreamPipeReaderOptions(_context.MemoryPool, _context.MemoryPool.GetMinimumSegmentSize(), _context.MemoryPool.GetMinimumAllocSize(), useZeroByteReads: true)); 99((PipeReader)self).Complete();

Internal\Http2\Http2Connection.cs (2)

209public PipeReader Input => _input.Reader; 1850private async Task CopyPipeAsync(PipeReader reader, PipeWriter writer)

Internal\Http2\Http2FrameWriter.cs (1)

186var reader = producer.PipeReader;

Internal\Http2\Http2OutputProducer.cs (2)

34private readonly PipeReader _pipeReader; 81public PipeReader PipeReader => _pipeReader;

Internal\Http3\Http3ControlStream.cs (1)

75public PipeReader Input => _context.Transport.Input;

Internal\Http3\Http3OutputProducer.cs (1)

26private readonly PipeReader _pipeReader;

Internal\Http3\Http3PendingStream.cs (1)

42var Input = context.Transport.Input;

Internal\Http3\Http3Stream.cs (1)

86public PipeReader Input => _context.Transport.Input;

Internal\Infrastructure\BodyControl.cs (1)

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

Middleware\TlsListener.cs (1)

24var input = connection.Transport.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) 27public PipeReader Input { get; }

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

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

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

30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }

Http2\Http2FrameWriterTests.cs (1)

100public static async Task<byte[]> ReadForLengthAsync(this PipeReader pipeReader, int length)

HttpConnectionTests.cs (1)

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

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

35public PipeReader Input { get; } 63private readonly PipeReader _input; 65public PassThroughPipeReader(PipeReader input)

TestHelpers\ObservablePipeReader.cs (2)

13private readonly PipeReader _inner; 15public ObservablePipeReader(PipeReader reader)

ChunkWriterBenchmark.cs (1)

16private PipeReader _reader;

Http1LargeWritingBenchmark.cs (1)

95var reader = _pair.Application.Input;

Http1ReadingBenchmark.cs (1)

125var reader = _pair.Application.Input;

Http1WritingBenchmark.cs (1)

129var reader = _pair.Application.Input;

Http2\Http2ConnectionBenchmarkBase.cs (1)

152internal async ValueTask ReceiveFrameAsync(PipeReader pipeReader, uint maxFrameSize = Http2PeerSettings.DefaultMaxFrameSize)

InMemoryTransportBenchmark.cs (1)

184public PipeReader Output => Application.Input;

Mocks\MockDuplexPipe.cs (2)

10public MockDuplexPipe(PipeReader input, PipeWriter output) 16public PipeReader Input { get; }

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

12private readonly PipeReader _inner; 18public CompletionPipeReader(PipeReader inner)

Internal\NamedPipeConnection.cs (1)

59public PipeReader Output => Application.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) 27public PipeReader Input { get; }

Internal\QuicStreamContext.cs (2)

75private PipeReader Output => Application.Input; 380var output = Output;

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

12private readonly PipeReader _inner; 18public CompletionPipeReader(PipeReader 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) 27public PipeReader Input { get; }

Internal\SocketConnection.cs (1)

74public PipeReader Output => Application.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) 27public PipeReader Input { get; }

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) 27public PipeReader Input { get; }

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

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

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

30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }

HubConnection.cs (2)

1509var input = startingConnectionState.Connection.Transport.Input; 1634var input = connectionState.Connection.Transport.Input;

TestTransport.cs (1)

25public PipeReader Input => _transport.Input;

HubConnectionContext.cs (3)

25private static readonly Action<object?> _cancelReader = state => ((PipeReader)state!).CancelPendingRead(); 159internal PipeReader Input => _connectionContext.Transport.Input; 498var input = Input;

HubConnectionHandler.cs (1)

265var input = connection.Input;

Shared\TestDuplexPipe.cs (1)

12public PipeReader Input => _input;

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

8public DuplexPipe(PipeReader reader, PipeWriter writer) 14public PipeReader Input { get; }

EndToEndTests.cs (1)

707public PipeReader Input => _transport.Input;

HubConnectionHandlerTests.cs (4)

2934private readonly PipeReader _originalPipeReader; 2938public PipeReaderWrapper(PipeReader pipeReader) 2999public PipeReader Input => WrappedPipeReader; 5303var prevPipe = connection.Application.Input;

Internal\MessageBufferTests.cs (2)

565public DuplexPipe(PipeReader reader, PipeWriter writer) 571public PipeReader Input { get; }

PipeReaderExtensions.cs (5)

10public static async Task<bool> WaitToReadAsync(this PipeReader pipeReader) 36public static async Task<byte[]> ReadSingleAsync(this PipeReader pipeReader) 53public static async Task ConsumeAsync(this PipeReader pipeReader, int numBytes) 69public static async Task<byte[]> ReadAllAsync(this PipeReader pipeReader) 85public static async Task<byte[]> ReadAsync(this PipeReader pipeReader, int numBytes)

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

8public DuplexPipe(PipeReader reader, PipeWriter writer) 14public PipeReader Input { get; }

HttpContextBuilder.cs (1)

61internal void Configure(Action<HttpContext, PipeReader> configureContext)

FormPipeReader.cs (5)

36private readonly PipeReader _pipeReader; 42/// <param name="pipeReader">The <see cref="PipeReader"/> to read from.</param> 43public FormPipeReader(PipeReader pipeReader) 51/// <param name="pipeReader">The <see cref="PipeReader"/> to read from.</param> 53public FormPipeReader(PipeReader pipeReader, Encoding encoding)

FormPipeReaderTests.cs (17)

ISolutionAssetProvider.cs (1)

24/// the code that reads from the corresponding <see cref="PipeReader"/> side of this.</param>

RemoteCallback.cs (3)

96/// cref="PipeReader"/>, but no harm will happen if it does.</param> 100Func<PipeReader, CancellationToken, ValueTask> reader, 173async Task ReadAsync(PipeReader pipeReader)

RemoteHostAssetReader.cs (2)

21PipeReader pipeReader, 28private readonly PipeReader _pipeReader = pipeReader;

Remote\ServiceDescriptorTests.cs (1)

133type != typeof(PipeReader) &&

RuntimeValidatableParameterInfoResolver.cs (1)

100type == typeof(PipeReader))

ValidationsGeneratorTestBase.cs (1)

58MetadataReference.CreateFromFile(typeof(PipeReader).Assembly.Location),

RuntimeValidatableParameterInfoResolverTests.cs (1)

44[InlineData(typeof(PipeReader))]

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

35public PipeReader Input { get; } 63private readonly PipeReader _input; 65public PassThroughPipeReader(PipeReader input)

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

84public PipeReader Input => new MockPipeReader(this);

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

9/// <summary>Gets the <see cref="System.IO.Pipelines.PipeReader" /> half of the duplex pipe.</summary> 10PipeReader Input { 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> 1164/// <summary>Gets the <see cref="System.IO.Pipelines.PipeReader" /> for this pipe.</summary> 1165/// <value>A <see cref="System.IO.Pipelines.PipeReader" /> instance for this pipe.</value> 1166public PipeReader Reader => _reader;

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 (3)

20/// <param name="readerScheduler">The <see cref="System.IO.Pipelines.PipeScheduler" /> to be used to execute <see cref="System.IO.Pipelines.PipeReader" /> callbacks and async continuations.</param> 108/// <summary>Gets the <see cref="System.IO.Pipelines.PipeScheduler" /> used to execute <see cref="System.IO.Pipelines.PipeReader" /> callbacks and async continuations.</summary> 109/// <value>A <see cref="System.IO.Pipelines.PipeScheduler" /> that is used to execute <see cref="System.IO.Pipelines.PipeReader" /> callbacks and async continuations.</value>

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

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

14private readonly PipeReader _pipeReader; 16public PipeReaderStream(PipeReader pipeReader, bool leaveOpen)

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 (4)

43/// <summary>Registers a callback that executes when the <see cref="System.IO.Pipelines.PipeReader" /> side of the pipe is completed.</summary> 56/// <summary>Makes bytes written available to <see cref="System.IO.Pipelines.PipeReader" /> and runs <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> continuation.</summary> 109/// <summary>Writes the specified byte memory range to the pipe and makes data accessible to the <see cref="System.IO.Pipelines.PipeReader" />.</summary>

System\IO\Pipelines\ReadResult.cs (9)

System\IO\Pipelines\StreamPipeReaderOptions.cs (7)

System\Text\Json\Serialization\JsonSerializer.Read.Pipe.cs (12)

44PipeReader utf8Json, 74PipeReader utf8Json, 103PipeReader utf8Json, 142PipeReader utf8Json, 181PipeReader utf8Json, 208PipeReader utf8Json, 228PipeReader utf8Json, 255PipeReader utf8Json, 289PipeReader utf8Json, 301PipeReader utf8Json, 323PipeReader utf8Json, 341success = listTypeInfo.ContinueDeserialize<PipeReadBufferState, PipeReader>(

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

1046internal abstract ValueTask<object?> DeserializeAsObjectAsync(PipeReader utf8Json, CancellationToken cancellationToken);

System\Text\Json\Serialization\Metadata\JsonTypeInfoOfT.ReadHelper.cs (3)

65internal ValueTask<T?> DeserializeAsync(PipeReader utf8Json, CancellationToken cancellationToken) 123internal sealed override async ValueTask<object?> DeserializeAsObjectAsync(PipeReader utf8Json, CancellationToken cancellationToken) 125T? result = await DeserializeAsync<PipeReadBufferState, PipeReader>(utf8Json, bufferState: new PipeReadBufferState(utf8Json), cancellationToken).ConfigureAwait(false);

System\Text\Json\Serialization\PipeReadBufferState.cs (5)

14internal struct PipeReadBufferState : IReadBufferState<PipeReadBufferState, PipeReader> 16private readonly PipeReader _utf8Json; 23public PipeReadBufferState(PipeReader utf8Json) 53public async ValueTask<PipeReadBufferState> ReadAsync(PipeReader utf8Json, CancellationToken cancellationToken, bool fillBuffer = true) 76public void Read(PipeReader utf8Json) => throw new NotImplementedException();

Program.cs (2)

95var inputPipe = stream.Transport.Input; 115var inputPipe = stream.Transport.Input;