TransformManyBlock<TInput,TOutput> 類別

定義

提供一個資料流區塊,為每個收到的資料元素調用所提供的 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>指定資料輸出類型。

繼承
TransformManyBlock<TInput,TOutput>
實作

備註

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

建構函式

名稱 Description
TransformManyBlock<TInput,TOutput>(Func<TInput,IAsyncEnumerable<TOutput>>, ExecutionDataflowBlockOptions)

初始化 TransformManyBlock<TInput,TOutput> 為指定函數 和 ExecutionDataflowBlockOptions

TransformManyBlock<TInput,TOutput>(Func<TInput,IAsyncEnumerable<TOutput>>)

初始化 , TransformManyBlock<TInput,TOutput> 使用指定的函式。

TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>, ExecutionDataflowBlockOptions)

初始化 TransformManyBlock<TInput,TOutput> 一個新函數,包含指定的函數和 ExecutionDataflowBlockOptions

TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>)

初始化 TransformManyBlock<TInput,TOutput> 一個新函式,並使用指定函式。

TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>, ExecutionDataflowBlockOptions)

初始化 TransformManyBlock<TInput,TOutput> 一個新函數,包含指定的函數和 ExecutionDataflowBlockOptions

TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>)

初始化 TransformManyBlock<TInput,TOutput> 一個新函式,並使用指定函式。

屬性

名稱 Description
Completion

會得到 Task 一個,代表非同步操作及資料流區塊的完成。

InputCount

取得該區塊等待處理的輸入項目數量。

OutputCount

取得該區塊可接收的輸出項目數量。

方法

名稱 Description
Complete()

向 S 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>

明確介面實作

名稱 Description
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> 者呼叫,釋放先前被保留 DataflowMessageHeaderISourceBlock<TOutput>

ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

由連結ITargetBlock<TInput>者致電預訂,之前由此DataflowMessageHeader服務ISourceBlock<TOutput>提供。

ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)

向 ,提供訊息 ITargetBlock<TInput>,讓目標有機會接收或延後該訊息。

擴充方法

名稱 Description
AsObservable<TOutput>(ISourceBlock<TOutput>)

在 上建立一個新的IObservable<T>抽象。ISourceBlock<TOutput>

AsObserver<TInput>(ITargetBlock<TInput>)

在 上建立一個新的IObserver<T>抽象。ITargetBlock<TInput>

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>

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

提供非同步監控來源可用輸出的 A Task<TResult>

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)

提供非同步監控來源可用輸出的 A 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>的項目。

適用於