Share via


PipeReader 类

定义

定义提供对管道读取端的访问权限的类。

public ref class PipeReader abstract
public abstract class PipeReader
type PipeReader = class
Public MustInherit Class PipeReader
继承
PipeReader

构造函数

PipeReader()

初始化 PipeReader 类的新实例。

方法

AdvanceTo(SequencePosition)

将管道的读取光标向前移动到已使用的数据之后,将数据标记为“已处理”。

AdvanceTo(SequencePosition, SequencePosition)

将管道的读取光标向前移动到已使用的数据之后,将数据标记为“已处理”、“已读取”和“已检查”。

AsStream(Boolean)

返回 StreamPipeReader 表示形式。

CancelPendingRead()

取消挂起的 ReadAsync(CancellationToken) 操作,而不会导致操作异常抛出,也不会完成 PipeReader。 如果没有挂起的操作,则取消下一个操作。

Complete(Exception)

对生成者发出使用者已完成读取的信号。

CompleteAsync(Exception)

将当前管道读取器实例标记为已完成,这意味着将不再从该实例中读取数据。

CopyToAsync(PipeWriter, CancellationToken)

使用指定缓冲区大小和取消标记从 PipeReader 中异步读取字节并将它们写入到指定 PipeWriter

CopyToAsync(Stream, CancellationToken)

使用指定的取消令牌从 PipeReader 中异步读取字节并将其写入到指定的流。

Create(ReadOnlySequence<Byte>)

创建包装指定的 ReadOnlySequence<T>PipeReader

Create(Stream, StreamPipeReaderOptions)

创建包装指定的 StreamPipeReader

Equals(Object)

确定指定对象是否等于当前对象。

(继承自 Object)
GetHashCode()

作为默认哈希函数。

(继承自 Object)
GetType()

获取当前实例的 Type

(继承自 Object)
MemberwiseClone()

创建当前 Object 的浅表副本。

(继承自 Object)
OnWriterCompleted(Action<Exception,Object>, Object)
已过时.
已过时.

注册管道的 PipeWriter 端已完成时执行的回调。

ReadAsync(CancellationToken)

以异步方式从当前 PipeReader 读取一系列字节。

ReadAtLeastAsync(Int32, CancellationToken)

以异步方式从当前 PipeReader 读取一系列字节。

ReadAtLeastAsyncCore(Int32, CancellationToken)

以异步方式从当前 PipeReader 读取一系列字节。

ToString()

返回表示当前对象的字符串。

(继承自 Object)
TryRead(ReadResult)

尝试同步读取数据 PipeReader

适用于