DataflowBlock クラス

定義

名前空間:
System.Threading.Tasks.Dataflow
アセンブリ:
System.Threading.Tasks.Dataflow.dll
パッケージ:
System.Threading.Tasks.Dataflow v11.0.0-preview.4.26230.115
ソース:
DataflowBlock.cs
ソース:
DataflowBlock.cs
ソース:
DataflowBlock.cs
ソース:
DataflowBlock.cs
ソース:
DataflowBlock.cs
ソース:
DataflowBlock.cs
ソース:
DataflowBlock.cs

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

public ref class DataflowBlock abstract sealed
public static class DataflowBlock
type DataflowBlock = class
Public Module DataflowBlock
継承
Object
DataflowBlock

注釈

Note

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>)

IObserver<T>に対する新しいITargetBlock<TInput>抽象化を作成します。
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions)

3 つのデータフロー ソースを監視し、指定されたハンドラーを呼び出して、最初にデータを使用可能にするソースを指定します。
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>)

3 つのデータフロー ソースを監視し、指定されたハンドラーを呼び出して、最初にデータを使用可能にするソースを指定します。
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions)

2 つのデータフロー ソースを監視し、指定されたハンドラーを呼び出して、最初にデータを使用可能にするソースを指定します。
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>)

2 つのデータフロー ソースを監視し、指定されたハンドラーを呼び出して、最初にデータを使用可能にするソースを指定します。
Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>)

ターゲットとソースを 1 つの伝達子にカプセル化します。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)

指定したフィルターを使用して、指定したISourceBlock<TOutput>にITargetBlock<TInput>をリンクします。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)

指定したフィルターを使用して、指定したISourceBlock<TOutput>にITargetBlock<TInput>をリンクします。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)

指定したISourceBlock<TOutput>にITargetBlock<TInput>をリンクします。
NullTarget<TInput>()

提供されるすべてのメッセージを同期的に受け入れてドロップするターゲット ブロックを取得します。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

ソースで使用可能な出力を非同期的に監視する Task<TResult> を提供します。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)

ソースで使用可能な出力を非同期的に監視する Task<TResult> を提供します。
Post<TInput>(ITargetBlock<TInput>, TInput)

アイテムを ITargetBlock<TInput>に投稿します。
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)

指定したソースから値を同期的に受信し、操作を取り消すトークンを提供します。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

指定したソースから値を同期的に受信し、操作を取り消すトークンを提供し、オプションのタイムアウト間隔を監視します。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)

指定したソースから値を同期的に受信し、オプションのタイムアウト期間を監視します。
Receive<TOutput>(ISourceBlock<TOutput>)

指定したソースから値を同期的に受信します。
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)

ソースからすべてのデータを受信できるようにする IAsyncEnumerable<T> を作成します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

指定したソースから値を非同期に受信し、操作を取り消すトークンを提供します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

指定したソースから値を非同期に受信し、操作を取り消すトークンを提供し、オプションのタイムアウト間隔を監視します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)

指定したソースから値を非同期に受信し、オプションのタイムアウト期間を監視します。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)

指定したソースから値を非同期的に受信します。
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)

ターゲット メッセージ ブロックにメッセージを非同期的に提供し、延期できるようにします。
SendAsync<TInput>(ITargetBlock<TInput>, TInput)

ターゲット メッセージ ブロックにメッセージを非同期的に提供し、延期できるようにします。
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)

ISourceBlock<TOutput>からアイテムを同期的に受信しようとします。

適用対象