Share via

IReceivableSourceBlock<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

表示支援接收訊息而不連結的資料流程區塊。

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> 提供的資料型別。

衍生
實作
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> 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>，以非同步方式監視可用輸出的來源。
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> 接收項目。

適用於