DataflowBlock クラス

定義

名前空間:

System.Threading.Tasks.Dataflow

アセンブリ:

System.Threading.Tasks.Dataflow.dll

データフロー ブロックを操作する静的 (Visual Basic の場合は共有) メソッドのセットを提供します。

public ref class DataflowBlock abstract sealed

public static class DataflowBlock

type DataflowBlock = class

Public Module DataflowBlock

継承

Object

DataflowBlock

注釈

注意

TPL データフロー ライブラリ (System.Threading.Tasks.Dataflow 名前空間) は、.NET と一緒には配布されません。 Visual Studio に System.Threading.Tasks.Dataflow 名前空間をインストールするには、プロジェクトを開き、 [プロジェクト] メニューの [NuGet パッケージの管理] をクリックし、System.Threading.Tasks.Dataflow パッケージをオンラインで検索します。 または、.NET Core CLI を使ってインストールするには、dotnet add package System.Threading.Tasks.Dataflow を実行します。

メソッド

AsObservable<TOutput>(ISourceBlock<TOutput>)	IObservable<T> の新しい ISourceBlock<TOutput> 抽象化を作成します。
AsObserver<TInput>(ITargetBlock<TInput>)	ITargetBlock<TInput> の新しい IObserver<T> 抽象化を作成します。
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>)	3 つのデータ フロー ソースを監視し、データが最初に使用できるようになったソースに対して、指定したハンドラーを呼び出します。
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions)	3 つのデータ フロー ソースを監視し、データが最初に使用できるようになったソースに対して、指定したハンドラーを呼び出します。
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>)	2 つのデータ フロー ソースを監視し、データが最初に使用できるようになったソースに対して、指定したハンドラーを呼び出します。
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions)	2 つのデータ フロー ソースを監視し、データが最初に使用できるようになったソースに対して、指定したハンドラーを呼び出します。
Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>)	ターゲットとソースを単一の伝達子にカプセル化します。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	指定した ITargetBlock<TInput> に ISourceBlock<TOutput> をリンクします。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	指定したフィルターを使用して、指定した ITargetBlock<TInput> に ISourceBlock<TOutput> をリンクします。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	指定したフィルターを使用して、指定した ITargetBlock<TInput> に ISourceBlock<TOutput> をリンクします。
NullTarget<TInput>()	提供されるすべてのメッセージを同期的に受け入れてドロップするターゲット ブロックを取得します。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	使用できる出力のソースを非同期的に監視する Task<TResult> を提供します。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	使用できる出力のソースを非同期的に監視する Task<TResult> を提供します。
Post<TInput>(ITargetBlock<TInput>, TInput)	ITargetBlock<TInput> に項目をポストします。
Receive<TOutput>(ISourceBlock<TOutput>)	指定されたソースから値を同期的に受信します。
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	同期的に指定したソースから値を受け取り、操作をキャンセルするトークンを提供します。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	同期的に指定したソースから値を受信し、オプションのタイムアウト期間を確認します。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	同期的に操作をキャンセルするトークンを提供し、オプションのタイムアウト間隔を確認する指定したソースから値を受け取ります。
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	IAsyncEnumerable<T>ソースからすべてのデータを受信できるようにするオブジェクトを作成します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	指定されたソースから値を非同期的に受信します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	非同期に指定したソースから値を受け取り、操作をキャンセルするトークンを提供します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	非同期に指定したソースから値を受信し、オプションのタイムアウト期間を確認します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	非同期に操作をキャンセルするトークンを提供し、オプションのタイムアウト間隔を確認する指定したソースから値を受け取ります。
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	ターゲット メッセージ ブロックにメッセージを非同期的に提供し、遅延を可能にします。
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	ターゲット メッセージ ブロックにメッセージを非同期的に提供し、遅延を可能にします。
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	ISourceBlock<TOutput> から使用可能な出力項目を同期的に受信します。