IAsyncObserver<T>.OnNextAsync(T, StreamSequenceToken) Metode

Definisi

Ruang nama:

Orleans.Streams

Rakitan:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v9.0.0

Meneruskan item berikutnya ke konsumen.

Tugas yang dikembalikan dari metode ini harus diselesaikan ketika pemrosesan item telah cukup diproses oleh konsumen untuk memenuhi jaminan perilaku apa pun.

Ketika konsumen adalah (titik akhir produsen) aliran, Tugas selesai ketika implementasi aliran telah menerima tanggung jawab untuk item tersebut dan dipastikan memenuhi jaminan pengirimannya. Misalnya, aliran berdasarkan antrean tahan lama akan menyelesaikan Tugas ketika item telah disimpan dengan tahan lama. Aliran yang memberikan upaya terbaik paling banyak sekali pengiriman akan mengembalikan Tugas yang sudah selesai.

Ketika produsen adalah (titik akhir konsumen) aliran, Tugas harus diselesaikan oleh kode konsumen ketika telah menerima tanggung jawab untuk item tersebut. Secara khusus, jika penyedia streaming menjamin pengiriman setidaknya sekali, maka item tidak boleh dianggap dikirimkan sampai Tugas yang dikembalikan oleh konsumen telah selesai.

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

Parameter

item

T

Item yang akan diteruskan.

token

StreamSequenceToken

Token urutan aliran item ini.

Mengembalikan

Task

Tugas yang selesai ketika item telah diterima.