Bagikan melalui


IAsyncObserver<T> Antarmuka

Definisi

Antarmuka ini menggeneralisasi antarmuka .NET IObserver standar untuk memungkinkan produksi item asinkron.

Perhatikan bahwa antarmuka ini diimplementasikan oleh konsumen item dan dipanggil (digunakan) oleh produsen item. Ini berarti bahwa titik akhir konsumen aliran mengimplementasikan antarmuka ini.

public interface IAsyncObserver<in T>
type IAsyncObserver<'T> = interface
Public Interface IAsyncObserver(Of In T)

Jenis parameter

T

Jenis objek yang dikonsumsi oleh pengamat.

Parameter jenis ini bersifat kontravarian. Artinya, Anda bisa menggunakan jenis yang Anda tentukan atau jenis apa pun yang tidak banyak diturunkan. Untuk informasi lebih lanjut tentang kovariansi dan kontravariansi, lihat Kovariansi dan Kontravariansi dalam Generik.
Turunan

Metode

OnCompletedAsync()

Memberi tahu konsumen bahwa aliran telah selesai.

Tugas yang dikembalikan dari metode ini harus diselesaikan ketika konsumen selesai memproses penutupan aliran.

OnErrorAsync(Exception)

Memberi tahu konsumen bahwa aliran mengalami kesalahan.

Tugas yang dikembalikan dari metode ini harus diselesaikan ketika konsumen selesai memproses penutupan aliran.

OnNextAsync(T, StreamSequenceToken)

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.

Berlaku untuk