IAsyncObservable<T> Antarmuka

Referensi

Definisi

Ruang nama:: Orleans.Streams

Rakitan:: Orleans.dll

Rakitan:: Orleans.Core.Abstractions.dll

Rakitan:: Orleans.Streaming.dll

Paket:: Microsoft.Orleans.Core v1.5.10

Paket:: Microsoft.Orleans.Core.Abstractions v2.4.5

Paket:: Microsoft.Orleans.Core.Abstractions v3.6.5

Paket:: Microsoft.Orleans.Streaming v7.2.5

Paket:: Microsoft.Orleans.Streaming v8.0.0

Paket:: Microsoft.Orleans.Streaming v8.1.0

Paket:: Microsoft.Orleans.Streaming v8.2.0

Paket:: Microsoft.Orleans.Streaming v9.0.0

Paket:: Microsoft.Orleans.Streaming v9.1.2

Sumber:: IAsyncObservable.cs

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 menggeneralisasi antarmuka .NET IObserveable standar untuk memungkinkan konsumsi item asinkron. Asinkron di sini berarti konsumen dapat memproses item secara asinkron dan penyelesaian item sinyal ke produsen dengan menyelesaikan Tugas yang dikembalikan.

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

public interface IAsyncObservable<T>

type IAsyncObservable<'T> = interface

Public Interface IAsyncObservable(Of T)

Jenis parameter

T

Jenis objek yang dihasilkan oleh yang dapat diamati.

Turunan: Orleans.Streams.IAsyncStream<T>

Metode

SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object)	Berlangganan konsumen untuk ini dapat diamati.
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	Berlangganan konsumen untuk ini dapat diamati.
SubscribeAsync(IAsyncObserver<T>)	Berlangganan konsumen untuk ini dapat diamati.

Metode Ekstensi

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)	Berlangganan konsumen ke pengamatan ini menggunakan delegasi. Metode ini adalah pembantu untuk IAsyncObservable.SubscribeAsync yang memungkinkan kelas berlangganan sebaris metode handler alih-alih memerlukan instans IAsyncObserver.

Berlaku untuk

Bagikan melalui