5 types derived from PipeReader
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\HttpRequestPipeReader.cs (1)
13internal sealed class HttpRequestPipeReader : PipeReader
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
10internal sealed class CompletionPipeReader : PipeReader
System.IO.Pipelines (3)
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
151 references to PipeReader
Aspire.Hosting (2)
Dcp\DcpHost.cs (2)
353var reader = PipeReader.Create(stream);
Microsoft.AspNetCore.Components.Server (1)
Circuits\RemoteJSDataStream.cs (1)
86public PipeReader PipeReader { get; }
Microsoft.AspNetCore.Http (5)
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
Microsoft.AspNetCore.Http.Abstractions (3)
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(); }
Microsoft.AspNetCore.Http.Connections (8)
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\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (2)
8public DuplexPipe(PipeReader reader, PipeWriter writer) 14public PipeReader Input { get; }
Microsoft.AspNetCore.Http.Extensions (2)
RequestDelegateFactory.cs (2)
757else if (parameter.ParameterType == typeof(PipeReader)) 871else if (parameter.ParameterType == typeof(PipeReader))
Microsoft.AspNetCore.Http.Features (3)
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; }
Microsoft.AspNetCore.Http.Results (6)
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,
Microsoft.AspNetCore.Server.Kestrel.Core (23)
Internal\Http\Http1Connection.cs (1)
98public 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)
213public PipeReader Input => _input.Reader; 1890private 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)
81public 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)
90public 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)
27var input = connection.Transport.Input;
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (3)
17/// two <see cref="PipeReader"/>s and two <see cref="PipeWriter"/>s - it is only how they are grouped that differs. 21public DuplexPipe(PipeReader reader, PipeWriter writer) 27public PipeReader Input { get; }
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
19private readonly PipeReader _input; 24public DuplexPipeStream(PipeReader input, PipeWriter output, bool throwOnCancelled = false)
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (2)
30Input = PipeReader.Create(stream, readerOptions); 36public PipeReader Input { get; }
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (7)
Internal\QuicStreamContext.cs (2)
75private PipeReader Output => Application.Input; 380var output = Output;
src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeReader.cs (2)
12private readonly PipeReader _inner; 18public CompletionPipeReader(PipeReader inner)
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (3)
17/// two <see cref="PipeReader"/>s and two <see cref="PipeWriter"/>s - it is only how they are grouped that differs. 21public DuplexPipe(PipeReader reader, PipeWriter writer) 27public PipeReader Input { get; }
Microsoft.AspNetCore.SignalR.Core (4)
HubConnectionContext.cs (3)
25private static readonly Action<object?> _cancelReader = state => ((PipeReader)state!).CancelPendingRead(); 159internal PipeReader Input => _connectionContext.Transport.Input; 535var input = Input;
HubConnectionHandler.cs (1)
265var input = connection.Input;
Microsoft.AspNetCore.WebUtilities (5)
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)
Microsoft.Extensions.Validation (1)
RuntimeValidatableParameterInfoResolver.cs (1)
148type == typeof(PipeReader))
System.IO.Pipelines (60)
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)
15/// <summary>Attempts to synchronously read data from the <see cref="System.IO.Pipelines.PipeReader" />.</summary> 29/// <summary>Asynchronously reads a sequence of bytes from the current <see cref="System.IO.Pipelines.PipeReader" />.</summary> 34/// <summary>Asynchronously reads a sequence of bytes from the current <see cref="System.IO.Pipelines.PipeReader" />.</summary> 40/// The call returns if the <see cref="System.IO.Pipelines.PipeReader" /> has read the minimumLength specified, or is cancelled or completed. 44/// further data is available. You should instead call <see cref="System.IO.Pipelines.PipeReader.TryRead" /> to avoid a blocking call. 47/// Subsequent calls to <see cref="System.IO.Pipelines.PipeReader.AdvanceTo(System.SequencePosition,System.SequencePosition)" /> should 61/// <summary>Asynchronously reads a sequence of bytes from the current <see cref="System.IO.Pipelines.PipeReader" />.</summary> 65/// <remarks>The call returns if the <see cref="System.IO.Pipelines.PipeReader" /> has read the minimumLength specified, or is cancelled or completed.</remarks> 86/// The <see cref="System.IO.Pipelines.ReadResult.Buffer" /> previously returned from <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> must not be accessed after this call. 87/// This is equivalent to calling <see cref="System.IO.Pipelines.PipeReader.AdvanceTo(System.SequencePosition,System.SequencePosition)" /> with identical examined and consumed positions. 96/// The <see cref="System.IO.Pipelines.ReadResult.Buffer" /> previously returned from <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> must not be accessed after this call. 100/// <summary>Returns a <see cref="System.IO.Stream" /> representation of the <see cref="System.IO.Pipelines.PipeReader" />.</summary> 101/// <param name="leaveOpen">An optional flag that indicates whether disposing the returned <see cref="System.IO.Stream" /> leaves <see cref="System.IO.Pipelines.PipeReader" /> open (<see langword="true" />) or completes <see cref="System.IO.Pipelines.PipeReader" /> (<see langword="false" />).</param> 102/// <returns>A stream that represents the <see cref="System.IO.Pipelines.PipeReader" />.</returns> 117/// <summary>Cancels the pending <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> operation without causing it to throw and without completing the <see cref="System.IO.Pipelines.PipeReader" />. If there is no pending operation, this cancels the next operation.</summary> 118/// <remarks>The canceled <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> operation returns a <see cref="System.IO.Pipelines.ReadResult" /> where <see cref="System.IO.Pipelines.ReadResult.IsCanceled" /> is <see langword="true" />.</remarks> 154/// <summary>Creates a <see cref="System.IO.Pipelines.PipeReader" /> wrapping the specified <see cref="System.IO.Stream" />.</summary> 157/// <returns>A <see cref="System.IO.Pipelines.PipeReader" /> that wraps the <see cref="System.IO.Stream" />.</returns> 158public static PipeReader Create(Stream stream, StreamPipeReaderOptions? readerOptions = null) 164/// Creates a <see cref="PipeReader"/> wrapping the specified <see cref="ReadOnlySequence{T}"/>. 167/// <returns>A <see cref="PipeReader"/> that wraps the <see cref="ReadOnlySequence{T}"/>.</returns> 168public static PipeReader Create(ReadOnlySequence<byte> sequence) 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> 195/// <summary>Asynchronously reads the bytes from the <see cref="System.IO.Pipelines.PipeReader" /> and writes them to the specified stream, using a specified cancellation token.</summary>
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)
8/// <summary>Represents the result of a <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> call.</summary> 15/// <param name="buffer">The read-only sequence containing the bytes of data that were read in the <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> call.</param> 16/// <param name="isCanceled">A flag that indicates if the <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> operation that produced this <see cref="System.IO.Pipelines.ReadResult" /> was canceled by <see cref="System.IO.Pipelines.PipeReader.CancelPendingRead" />.</param> 34/// <value>A read-only sequence containing the bytes of data that were read in the <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> call.</value> 37/// <summary>Gets a value that indicates whether the current <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> operation was canceled by <see cref="System.IO.Pipelines.PipeReader.CancelPendingRead" />.</summary> 38/// <value><see langword="true" /> if the <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> operation that produced this <see cref="System.IO.Pipelines.ReadResult" /> was canceled by <see cref="System.IO.Pipelines.PipeReader.CancelPendingRead" />; otherwise, <see langword="false" />.</value>
System\IO\Pipelines\StreamPipeReaderOptions.cs (7)
8/// <summary>Represents a set of options for controlling the creation of the <see cref="System.IO.Pipelines.PipeReader" />.</summary> 17/// <summary>Initializes a <see cref="System.IO.Pipelines.StreamPipeReaderOptions" /> instance, optionally specifying a memory pool, a minimum buffer size, a minimum read size, and whether the underlying stream should be left open after the <see cref="System.IO.Pipelines.PipeReader" /> completes.</summary> 21/// <param name="leaveOpen"><see langword="true" /> to leave the underlying stream open after the <see cref="System.IO.Pipelines.PipeReader" /> completes; <see langword="false" /> to close it. The default is <see langword="false" />.</param> 28/// <summary>Initializes a <see cref="System.IO.Pipelines.StreamPipeReaderOptions" /> instance, optionally specifying a memory pool, a minimum buffer size, a minimum read size, and whether the underlying stream should be left open after the <see cref="System.IO.Pipelines.PipeReader" /> completes.</summary> 32/// <param name="leaveOpen"><see langword="true" /> to leave the underlying stream open after the <see cref="System.IO.Pipelines.PipeReader" /> completes; <see langword="false" /> to close it. The default is <see langword="false" />.</param> 71/// <summary>Gets the value that indicates if the underlying stream should be left open after the <see cref="System.IO.Pipelines.PipeReader" /> completes.</summary> 72/// <value><see langword="true" /> if the underlying stream should be left open after the <see cref="System.IO.Pipelines.PipeReader" /> completes; otherwise, <see langword="false" />.</value>
System.Text.Json (21)
System\Text\Json\Serialization\JsonSerializer.Read.Pipe.cs (12)
44PipeReader utf8Json, 74PipeReader utf8Json, 103PipeReader utf8Json, 142PipeReader utf8Json, 181PipeReader utf8Json, 208PipeReader utf8Json, 228PipeReader utf8Json, 257PipeReader utf8Json, 293PipeReader utf8Json, 305PipeReader utf8Json, 327PipeReader utf8Json, 345success = listTypeInfo.ContinueDeserialize<PipeReadBufferState, PipeReader>(
System\Text\Json\Serialization\Metadata\JsonTypeInfo.cs (1)
1524internal 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) 124internal sealed override async ValueTask<object?> DeserializeAsObjectAsync(PipeReader utf8Json, CancellationToken cancellationToken) 126T? 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();