IAsyncBatchObserver<T>.OnNextAsync 方法

定義

命名空間:

Orleans.Streams

組件:

Orleans.Streaming.dll

套件:

Microsoft.Orleans.Streaming v8.1.0

將下一批專案傳遞至取用者。

當取用者已充分處理專案處理，以符合任何行為保證時，應該完成從這個方法傳回的工作。

當取用者是) 資料流程的 (產生者端點時，當資料流程實作接受專案的責任，並確保符合其傳遞保證時，就會完成工作。 例如，根據長期佇列的資料流程會在專案永久儲存時完成工作。 最多一次傳遞時提供最佳工作的資料流程會傳回已經完成的工作。

當產生者是) 資料流程 (取用者端點時，當取用者程式碼接受專案的責任時，應該由取用者程式碼完成工作。 特別是，如果資料流程提供者保證至少傳遞一次，則在取用者傳回的工作完成之前，不應該將專案視為傳遞。

public System.Threading.Tasks.Task OnNextAsync (System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>> items);

abstract member OnNextAsync : System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>> -> System.Threading.Tasks.Task

Public Function OnNextAsync (items As IList(Of SequentialItem(Of T))) As Task

參數

items

IList<SequentialItem<T>>

要傳遞的專案。

傳回

Task

接受專案時完成的工作。