語言

DataflowBlock 類別

定義

命名空間:
System.Threading.Tasks.Dataflow
組件:
System.Threading.Tasks.Dataflow.dll
套件:
System.Threading.Tasks.Dataflow v11.0.0-rc.1.26425.128
來源:
DataflowBlock.cs
來源:
DataflowBlock.cs
來源:
DataflowBlock.cs
來源:
DataflowBlock.cs
來源:
DataflowBlock.cs
來源:
DataflowBlock.cs
來源:
DataflowBlock.cs
來源:
DataflowBlock.cs

提供一組靜態（可在 Visual Basic 中共享）方法來處理資料流區塊。

public ref class DataflowBlock abstract sealed
public static class DataflowBlock
type DataflowBlock = class
Public Module DataflowBlock
繼承
Object
DataflowBlock

方法

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

在 上建立一個新的IObservable<T>抽象。ISourceBlock<TOutput>
AsObserver<TInput>(ITargetBlock<TInput>)

在 上建立一個新的IObserver<T>抽象。ITargetBlock<TInput>
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions)

監控三個資料流來源，並呼叫先前提供資料來源的處理器。
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>)

監控三個資料流來源，並呼叫先前提供資料來源的處理器。
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions)

監控兩個資料流來源，並呼叫所提供的處理程序，針對最先提供資料的來源。
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>)

監控兩個資料流來源，並呼叫所提供的處理程序，針對最先提供資料的來源。
Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>)

將目標與源封裝於單一傳播器中。
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>。
NullTarget<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>的項目。

適用於