<PackageReference Include="System.IO.Pipelines" Version="11.0.0-rc.1.26425.128" />

System.IO.Pipelines.PipeReader

public abstract class PipeReader
Defines a class that provides access to a read side of pipe.
namespace System.IO.Pipelines { public abstract class PipeReader { public abstract bool TryRead(out ReadResult result); public abstract ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default(CancellationToken)); public ValueTask<ReadResult> ReadAtLeastAsync(int minimumSize, CancellationToken cancellationToken = default(CancellationToken)); protected virtual ValueTask<ReadResult> ReadAtLeastAsyncCore(int minimumSize, CancellationToken cancellationToken); public abstract void AdvanceTo(SequencePosition consumed); public abstract void AdvanceTo(SequencePosition consumed, SequencePosition examined); public virtual Stream AsStream(bool leaveOpen = false); public abstract void CancelPendingRead(); public abstract void Complete(Exception exception = null); public virtual ValueTask CompleteAsync(Exception exception = null); public virtual void OnWriterCompleted(Action<Exception, object> callback, object state); public static PipeReader Create(Stream stream, StreamPipeReaderOptions readerOptions = null); public static PipeReader Create(ReadOnlySequence<byte> sequence); public virtual Task CopyToAsync(PipeWriter destination, CancellationToken cancellationToken = default(CancellationToken)); public virtual Task CopyToAsync(Stream destination, CancellationToken cancellationToken = default(CancellationToken)); protected PipeReader(); } }