IAsyncObserver<T>.OnNextAsync(T, StreamSequenceToken) 方法

定義

命名空間:

Orleans.Streams

組件:

Orleans.Streaming.dll

套件:

Microsoft.Orleans.Streaming v8.1.0

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

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

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

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

public System.Threading.Tasks.Task OnNextAsync (T item, Orleans.Streams.StreamSequenceToken? token = default);

abstract member OnNextAsync : 'T * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task

Public Function OnNextAsync (item As T, Optional token As StreamSequenceToken = Nothing) As Task

參數

item

T

要傳遞的專案。

token

StreamSequenceToken

此專案的資料流程順序標記。

傳回

Task

接受專案時完成的工作。