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)

指定した Stream をラップする PipeReader を作成します。

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 で同期的にデータを読み取ろうとします。

適用対象