IReceivableSourceBlock<TOutput> インターフェイス

リファレンス

定義

名前空間:: System.Threading.Tasks.Dataflow

アセンブリ:: System.Threading.Tasks.Dataflow.dll

パッケージ:: System.Threading.Tasks.Dataflow v8.0.1

パッケージ:: System.Threading.Tasks.Dataflow v9.0.0-rc.1.24431.7

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

リンクせずにメッセージの受信をサポートするデータフローブロックを表します。

generic <typename TOutput>
public interface class IReceivableSourceBlock : System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>

public interface IReceivableSourceBlock<TOutput> : System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>

type IReceivableSourceBlock<'Output> = interface
    interface ISourceBlock<'Output>
    interface IDataflowBlock

type IReceivableSourceBlock<'Output> = interface
    interface IDataflowBlock
    interface ISourceBlock<'Output>

Public Interface IReceivableSourceBlock(Of TOutput)
Implements ISourceBlock(Of TOutput)

型パラメーター

TOutput

IReceivableSourceBlock<TOutput> によって提供されるデータの種類を指定します。

派生: System.Threading.Tasks.Dataflow.BatchBlock<T>

System.Threading.Tasks.Dataflow.BatchedJoinBlock<T1,T2>

System.Threading.Tasks.Dataflow.BatchedJoinBlock<T1,T2,T3>

System.Threading.Tasks.Dataflow.BroadcastBlock<T>

System.Threading.Tasks.Dataflow.BufferBlock<T>

その他…

実装: IDataflowBlock ISourceBlock<TOutput>

注釈

注意

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 を実行します。

プロパティ

Completion

データフローブロックの非同期操作と完了を表す Task を取得します。

(継承元 IDataflowBlock)

メソッド

Complete()	これ以上メッセージを受け付けまたは生成せず、延期メッセージを使用しないことを IDataflowBlock に通知します。 (継承元 IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	前にこの ITargetBlock<TInput> によって提供された DataflowMessageHeader を受け入れて使用するために、リンクされた ISourceBlock<TOutput> によって呼び出されます。 (継承元 ISourceBlock<TOutput>)
Fault(Exception)	IDataflowBlock を Faulted 状態で完了するようにします。 (継承元 IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	を ISourceBlock<TOutput> 指定したにリンクします ITargetBlock<TInput>。 (継承元 ISourceBlock<TOutput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	この ITargetBlock<TInput> によって前に予約された DataflowMessageHeader を解放するために、リンクされた ISourceBlock<TOutput> によって呼び出されます。 (継承元 ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	この ITargetBlock<TInput> によって前に提供された DataflowMessageHeader を予約するために、リンクされた ISourceBlock<TOutput> によって呼び出されます。 (継承元 ISourceBlock<TOutput>)
TryReceive(Predicate<TOutput>, TOutput)	使用可能な出力項目を IReceivableSourceBlock<TOutput> から同期的に受け取ろうとします。
TryReceiveAll(IList<TOutput>)	使用可能なすべての項目を IReceivableSourceBlock<TOutput> から同期的に受け取ろうとします。

拡張メソッド

AsObservable<TOutput>(ISourceBlock<TOutput>)	IObservable<T> の新しい ISourceBlock<TOutput> 抽象化を作成します。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	を ISourceBlock<TOutput> 指定したにリンクします ITargetBlock<TInput>。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	指定したフィルターを ISourceBlock<TOutput> 使用して、を指定 ITargetBlock<TInput> したにリンクします。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	指定したフィルターを ISourceBlock<TOutput> 使用して、を指定 ITargetBlock<TInput> したにリンクします。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	使用できる出力のソースを非同期的に監視する Task<TResult> を提供します。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	使用できる出力のソースを非同期的に監視する Task<TResult> を提供します。
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)	非同期に操作をキャンセルするトークンを提供し、オプションのタイムアウト間隔を確認する指定したソースから値を受け取ります。
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	ISourceBlock<TOutput> から使用可能な出力項目を同期的に受信します。

適用対象

次の方法で共有