IPropagatorBlock<TInput,TOutput> 介面

定義

命名空間:

System.Threading.Tasks.Dataflow

組件:

System.Threading.Tasks.Dataflow.dll

套件:

System.Threading.Tasks.Dataflow v9.0.0-preview.3.24172.9

表示同時為資料目標及資料來源的資料流程區塊。

generic <typename TInput, typename TOutput>
public interface class IPropagatorBlock : System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ITargetBlock<TInput>

public interface IPropagatorBlock<in TInput,out TOutput> : System.Threading.Tasks.Dataflow.ISourceBlock<out TOutput>, System.Threading.Tasks.Dataflow.ITargetBlock<in TInput>

type IPropagatorBlock<'Input, 'Output> = interface
    interface ITargetBlock<'Input>
    interface IDataflowBlock
    interface ISourceBlock<'Output>

Public Interface IPropagatorBlock(Of In TInput, Out TOutput)
Implements ISourceBlock(Of Out TOutput), ITargetBlock(Of In TInput)

類型參數

TInput

指定 IPropagatorBlock<TInput,TOutput> 接受的資料型別。

這是反變數的型別參數。 也就是說，您可以使用您指定的類型，或衍生程度較低的任何類型。 如需共變數與反變數的詳細資訊，請參閱泛型中的共變數與反變數。

TOutput

指定 IPropagatorBlock<TInput,TOutput> 提供的資料型別。

這是共變數的型別參數。 也就是說，您可以使用您指定的類型，或衍生程度較高的任何類型。 如需共變數與反變數的詳細資訊，請參閱泛型中的共變數與反變數。

衍生

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

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

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

System.Threading.Tasks.Dataflow.TransformBlock<TInput,TOutput>

System.Threading.Tasks.Dataflow.TransformManyBlock<TInput,TOutput>

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

實作

IDataflowBlock ISourceBlock<TOutput> ITargetBlock<TInput>

備註

注意

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>)
OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	提供了訊息給ITargetBlock<TInput>，讓目標有機會使用或延後訊息。 (繼承來源 ITargetBlock<TInput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	由連結的ITargetBlock<TInput>呼叫以釋出先前由此 DataflowMessageHeader 保留的 ISourceBlock<TOutput>。 (繼承來源 ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	由連結的ITargetBlock<TInput>呼叫以保留先前由此 DataflowMessageHeader 提供的 ISourceBlock<TOutput>。 (繼承來源 ISourceBlock<TOutput>)

擴充方法

AsObservable<TOutput>(ISourceBlock<TOutput>)	建立在 IObservable<T> 之上的新 ISourceBlock<TOutput> Abstraction。
AsObserver<TInput>(ITargetBlock<TInput>)	建立在 IObserver<T> 之上的新 ITargetBlock<TInput> Abstraction。
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>，以非同步方式監視可用輸出的來源。
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)	同步接收指定之來源的值，提供語彙基元取消作業並觀察選擇性逾時間隔。
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)	非同步提供訊息給目標訊息區，並允許延遲。