IAsyncStream<T> Antarmuka
Penting
Beberapa informasi terkait produk prarilis yang dapat diubah secara signifikan sebelum dirilis. Microsoft tidak memberikan jaminan, tersirat maupun tersurat, sehubungan dengan informasi yang diberikan di sini.
Antarmuka ini mewakili objek yang berfungsi sebagai pertemuan terdistribusi antara produsen dan konsumen.
Ini mirip dengan Kerangka Kerja Subject
Reaktif dan mengimplementasikan IObserver
atau IObservable
antarmuka.
public interface IAsyncStream<T> : IComparable<Orleans.Streams.IAsyncStream<T>>, IEquatable<Orleans.Streams.IAsyncStream<T>>, Orleans.Streams.IAsyncBatchObserver<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IStreamIdentity
public interface IAsyncStream<T> : IComparable<Orleans.Streams.IAsyncStream<T>>, IEquatable<Orleans.Streams.IAsyncStream<T>>, Orleans.Streams.IAsyncBatchObservable<T>, Orleans.Streams.IAsyncBatchProducer<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IStreamIdentity
public interface IAsyncStream<T> : IComparable<Orleans.Streams.IAsyncStream<T>>, IEquatable<Orleans.Streams.IAsyncStream<T>>, Orleans.Streams.IAsyncBatchObservable<T>, Orleans.Streams.IAsyncBatchProducer<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IAsyncStream
type IAsyncStream<'T> = interface
interface IStreamIdentity
interface IEquatable<IAsyncStream<'T>>
interface IComparable<IAsyncStream<'T>>
interface IAsyncObservable<'T>
interface IAsyncBatchObserver<'T>
interface IAsyncObserver<'T>
type IAsyncStream<'T> = interface
interface IStreamIdentity
interface IEquatable<IAsyncStream<'T>>
interface IComparable<IAsyncStream<'T>>
interface IAsyncObservable<'T>
interface IAsyncBatchObservable<'T>
interface IAsyncBatchProducer<'T>
interface IAsyncObserver<'T>
type IAsyncStream<'T> = interface
interface IAsyncStream
interface IEquatable<IAsyncStream<'T>>
interface IComparable<IAsyncStream<'T>>
interface IAsyncObservable<'T>
interface IAsyncBatchObservable<'T>
interface IAsyncBatchProducer<'T>
interface IAsyncObserver<'T>
Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObserver(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T)), IStreamIdentity
Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObservable(Of T), IAsyncBatchProducer(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T)), IStreamIdentity
Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObservable(Of T), IAsyncBatchProducer(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IAsyncStream, IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T))
- T
Jenis objek yang mengalir melalui aliran.
- Penerapan
Guid |
Mendapatkan pengidentifikasi unik. (Diperoleh dari IStreamIdentity) |
Is |
Menentukan apakah ini adalah aliran yang dapat digulung balik - mendukung berlangganan dari titik waktu sebelumnya. |
Namespace |
Mendapatkan namespace. (Diperoleh dari IStreamIdentity) |
Provider |
Nama Penyedia Aliran. |
Stream |
Mendapatkan pengidentifikasi aliran. (Diperoleh dari IAsyncStream) |
Get |
Mengambil daftar semua langganan aktif yang dibuat oleh pemanggil untuk aliran ini. |
On |
Memberi tahu konsumen bahwa aliran telah selesai. Tugas yang dikembalikan dari metode ini harus diselesaikan ketika konsumen selesai memproses penutupan aliran. (Diperoleh dari IAsyncObserver<T>) |
On |
Memberi tahu konsumen bahwa aliran mengalami kesalahan. Tugas yang dikembalikan dari metode ini harus diselesaikan ketika konsumen selesai memproses penutupan aliran. (Diperoleh dari IAsyncObserver<T>) |
On |
Meneruskan batch item berikutnya kepada konsumen. Tugas yang dikembalikan dari metode ini harus diselesaikan ketika pemrosesan item telah diproses dengan cukup oleh konsumen untuk memenuhi jaminan perilaku apa pun. Ketika konsumen adalah (titik akhir produsen) aliran, Tugas selesai ketika implementasi aliran telah menerima tanggung jawab atas item 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. Secara khusus, jika penyedia streaming menjamin pengiriman setidaknya sekali, item tidak boleh dianggap dikirimkan sampai Tugas yang dikembalikan oleh konsumen telah selesai. (Diperoleh dari IAsyncBatchObserver<T>) |
On |
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. (Diperoleh dari IAsyncObserver<T>) |
On |
Meneruskan batch item berikutnya kepada konsumen. Tugas yang dikembalikan dari metode ini harus diselesaikan ketika semua item dalam batch telah cukup diproses oleh konsumen untuk memenuhi jaminan perilaku apa pun. Artinya, semantik Tugas yang dikembalikan sama dengan OnNextAsync(T, StreamSequenceToken), diperluas untuk semua item dalam batch. (Diperoleh dari IAsyncBatchProducer<T>) |
Subscribe |
Berlangganan konsumen ke batch ini yang dapat diamati. (Diperoleh dari IAsyncBatchObservable<T>) |
Subscribe |
Berlangganan konsumen ke batch ini yang dapat diamati. (Diperoleh dari IAsyncBatchObservable<T>) |
Subscribe |
Berlangganan konsumen ke pengamatan ini. (Diperoleh dari IAsyncObservable<T>) |
Subscribe |
Berlangganan konsumen ke pengamatan ini. (Diperoleh dari IAsyncObservable<T>) |
Subscribe |
Berlangganan konsumen ke pengamatan ini. (Diperoleh dari IAsyncObservable<T>) |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncBatchObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncBatchObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncBatchObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncBatchObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncBatchObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncBatchObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncBatchObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncBatchObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |
Subscribe |
Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver. |