IAsyncObservable<T>.SubscribeAsync Metode

Definisi

Ruang nama:: Orleans.Streams

Rakitan:: Orleans.dll

Rakitan:: Orleans.Streaming.dll

Rakitan:: Orleans.Core.Abstractions.dll

Paket:: Microsoft.Orleans.Core v1.5.10

Paket:: Microsoft.Orleans.Streaming v10.0.0

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

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.

Overload

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

SubscribeAsync(IAsyncObserver<T>)

Sumber:: IAsyncObservable.cs

Berlangganan konsumen untuk ini dapat diamati.

public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync(Orleans.Streams.IAsyncObserver<T> observer);

abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

Public Function SubscribeAsync (observer As IAsyncObserver(Of T)) As Task(Of StreamSubscriptionHandle(Of T))

Parameter

observer: IAsyncObserver<T>

Pengamat asinkron untuk berlangganan.

Mengembalikan

Task<StreamSubscriptionHandle<T>>

Janji untuk StreamSubscriptionHandle yang mewakili langganan. Konsumen dapat berhenti berlangganan dengan menggunakan handel ini. Langganan tetap aktif selama tidak berhenti berlangganan secara eksplisit.

Berlaku untuk

SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)

Berlangganan konsumen untuk ini dapat diamati.

public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync(Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken? token, string? filterData = default);

abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken * string -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

Public Function SubscribeAsync (observer As IAsyncObserver(Of T), token As StreamSequenceToken, Optional filterData As String = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Parameter

observer: IAsyncObserver<T>

Pengamat asinkron untuk berlangganan.

token: StreamSequenceToken

Urutan aliran yang akan digunakan sebagai offset untuk memulai langganan.

filterData: String

Objek data yang akan diteruskan ke filter.

Mengembalikan

Task<StreamSubscriptionHandle<T>>

Berlaku untuk

SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object)

Sumber:: IAsyncObservable.cs

Berlangganan konsumen untuk ini dapat diamati.

public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync(Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);

abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

Public Function SubscribeAsync (observer As IAsyncObserver(Of T), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Parameter

observer: IAsyncObserver<T>

Pengamat asinkron untuk berlangganan.

token: StreamSequenceToken

Urutan aliran yang akan digunakan sebagai offset untuk memulai langganan.

filterFunc: StreamFilterPredicate

Filter yang akan diterapkan untuk langganan ini

filterData: Object

Objek data yang akan diteruskan ke filterFunc. Ini biasanya akan berisi paramater apa pun yang diperlukan oleh filterFunc untuk membuat keputusan pemfilteran.

Mengembalikan

Task<StreamSubscriptionHandle<T>>

Janji untuk StreamSubscriptionHandle yang mewakili langganan. Konsumen dapat berhenti berlangganan dengan menggunakan handel ini. Langganan tetap aktif selama langganan tidak berhenti berlangganan secara eksplisit.

Pengecualian

ArgumentException

Disingkirkan jika fungsi filter aliran yang disediakan tidak cocok. Biasanya ini karena ini bukan metode statis.

Berlaku untuk