|
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> から使用可能な出力項目を同期的に受信します。
|