TransformManyBlock<TInput,TOutput> 類別

參考

定義

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

組件:: System.Threading.Tasks.Dataflow.dll

套件:: System.Threading.Tasks.Dataflow v8.0.0

套件:: System.Threading.Tasks.Dataflow v9.0.0-preview.3.24172.9

來源:: TransformManyBlock.cs

來源:: TransformManyBlock.cs

來源:: TransformManyBlock.cs

重要

部分資訊涉及發行前產品，在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊，不做任何明確或隱含的瑕疵擔保。

提供資料流程區塊，為每個收到的資料項目叫用提供的 Func<T,TResult> 委派。

generic <typename TInput, typename TOutput>
public ref class TransformManyBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<TInput, TOutput>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ITargetBlock<TInput>

public sealed class TransformManyBlock<TInput,TOutput> : System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput,TOutput>, System.Threading.Tasks.Dataflow.IReceivableSourceBlock<TOutput>, System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>, System.Threading.Tasks.Dataflow.ITargetBlock<TInput>

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

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

Public NotInheritable Class TransformManyBlock(Of TInput, TOutput)
Implements IPropagatorBlock(Of TInput, TOutput), IReceivableSourceBlock(Of TOutput), ISourceBlock(Of TOutput), ITargetBlock(Of TInput)

類型參數

TInput

指定由這個 TransformManyBlock<TInput,TOutput> 接收和作業的資料型別。

TOutput

指定這個 TransformManyBlock<TInput,TOutput> 產生的資料輸出類型。

繼承: Object
TransformManyBlock<TInput,TOutput>

實作: IDataflowBlock IPropagatorBlock<TInput,TOutput> IReceivableSourceBlock<TOutput> 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) 加以安裝。

建構函式

TransformManyBlock<TInput,TOutput>(Func<TInput,IAsyncEnumerable<TOutput>>)	TransformManyBlock<TInput,TOutput>使用指定的函式初始化。
TransformManyBlock<TInput,TOutput>(Func<TInput,IAsyncEnumerable<TOutput>>, ExecutionDataflowBlockOptions)	TransformManyBlock<TInput,TOutput>使用指定的函式和 ExecutionDataflowBlockOptions ，初始化。
TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>)	使用指定的函式，初始化新的 TransformManyBlock<TInput,TOutput>。
TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>, ExecutionDataflowBlockOptions)	使用指定的函式和 TransformManyBlock<TInput,TOutput>，初始化新的 ExecutionDataflowBlockOptions。
TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>)	使用指定的函式，初始化新的 TransformManyBlock<TInput,TOutput>。
TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>, ExecutionDataflowBlockOptions)	使用指定的函式和 TransformManyBlock<TInput,TOutput>，初始化新的 ExecutionDataflowBlockOptions。

屬性

Completion	取得 Task，其表示非同步作業和資料流程區塊的完成。
InputCount	取得等候由這個區塊處理的輸入項目的數目。
OutputCount	取得可從此區塊接收的輸出項目數目。

方法

Complete()	向 IDataflowBlock 發出訊號，表示不應接受也不應產生任何其他訊息，也不應使用任何其他延後的訊息。
Equals(Object)	判斷指定的物件是否等於目前的物件。 (繼承來源 Object)
GetHashCode()	做為預設雜湊函式。 (繼承來源 Object)
GetType()	取得目前執行個體的 Type。 (繼承來源 Object)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	ISourceBlock<TOutput>將連結到指定的 ITargetBlock<TInput> 。
MemberwiseClone()	建立目前 Object 的淺層複製。 (繼承來源 Object)
ToString()	傳回表示這個 IDataflowBlock 執行個體之格式化名稱的字串。
TryReceive(Predicate<TOutput>, TOutput)	嘗試以同步方式從 IReceivableSourceBlock<TOutput> 接收可用的輸出項目。
TryReceiveAll(IList<TOutput>)	嘗試以同步方式從 IReceivableSourceBlock<TOutput> 接收所有可用項目。

明確介面實作

IDataflowBlock.Fault(Exception)	造成 IDataflowBlock 在 Faulted 狀態下完成。
ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	由連結的ITargetBlock<TInput>呼叫以接受及使用先前由此 DataflowMessageHeader 提供的 ISourceBlock<TOutput>。
ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	由連結的ITargetBlock<TInput>呼叫以釋出先前由此 DataflowMessageHeader 保留的 ISourceBlock<TOutput>。
ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	由連結的ITargetBlock<TInput>呼叫以保留先前由此 DataflowMessageHeader 提供的 ISourceBlock<TOutput>。
ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	提供了訊息給ITargetBlock<TInput>，讓目標有機會使用或延後訊息。

擴充方法

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)	同步接收指定之來源的值，提供語彙基元取消作業並觀察選擇性逾時間隔。
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> 接收項目。

適用於

TransformManyBlock<TInput,TOutput> 類別

定義

類型參數

備註

建構函式

屬性

方法

明確介面實作

擴充方法

適用於

意見反應

其他資源