AsyncObservableExtensions.SubscribeAsync Metode
Definisi
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
| 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. |
| 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>) |
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>, 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>) |
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>, 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>, 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, 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, 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>)
- Sumber:
- AsyncObservableExtensions.cs
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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task)) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegasikan yang dipanggil untuk IAsyncObserver.OnNextAsync.
Mengembalikan
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<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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegasikan yang dipanggil untuk IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Urutan aliran yang akan digunakan sebagai offset untuk memulai langganan.
Mengembalikan
Janji untuk StreamSubscriptionHandle yang mewakili langganan. Konsumen dapat berhenti berlangganan dengan menggunakan handel ini. Langganan tetap aktif selama tidak berhenti berlangganan secara eksplisit.
Pengecualian
Disingkirkan jika fungsi filter aliran yang disediakan tidak cocok. Biasanya ini karena ini bukan metode statis.
Berlaku untuk
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)
- Sumber:
- AsyncObservableExtensions.cs
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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task)) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegasikan yang dipanggil untuk IAsyncObserver.OnNextAsync.
Mengembalikan
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<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)
- Sumber:
- AsyncObservableExtensions.cs
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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegasikan yang dipanggil untuk IAsyncObserver.OnNextAsync.
Mengembalikan
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<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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegasikan yang dipanggil untuk IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Urutan aliran yang akan digunakan sebagai offset untuk memulai langganan.
Mengembalikan
Janji untuk StreamSubscriptionHandle yang mewakili langganan. Konsumen dapat berhenti berlangganan dengan menggunakan handel ini. Langganan tetap aktif selama tidak berhenti berlangganan secara eksplisit.
Pengecualian
Disingkirkan jika fungsi filter aliran yang disediakan tidak cocok. Biasanya ini karena ini bukan metode statis.
Berlaku untuk
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)
- Sumber:
- AsyncObservableExtensions.cs
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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegasikan yang dipanggil untuk IAsyncObserver.OnNextAsync.
Mengembalikan
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<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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegasikan yang dipanggil untuk IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Urutan aliran yang akan digunakan sebagai offset untuk memulai langganan.
Mengembalikan
Janji untuk StreamSubscriptionHandle yang mewakili langganan. Konsumen dapat berhenti berlangganan dengan menggunakan handel ini. Langganan tetap aktif selama tidak berhenti berlangganan secara eksplisit.
Pengecualian
Disingkirkan jika fungsi filter aliran yang disediakan tidak cocok. Biasanya ini karena ini bukan metode statis.
Berlaku untuk
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Sumber:
- AsyncObservableExtensions.cs
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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte yang dipanggil untuk IAsyncObserver.OnNextAsync.
- 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
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
Disingkirkan jika fungsi filter aliran yang disediakan tidak cocok. Biasanya ini karena ini bukan metode statis.
Berlaku untuk
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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegasikan yang dipanggil untuk IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Urutan aliran yang akan digunakan sebagai offset untuk memulai langganan.
Mengembalikan
Janji untuk StreamSubscriptionHandle yang mewakili langganan. Konsumen dapat berhenti berlangganan dengan menggunakan handel ini. Langganan tetap aktif selama tidak berhenti berlangganan secara eksplisit.
Pengecualian
Disingkirkan jika fungsi filter aliran yang disediakan tidak cocok. Biasanya ini karena ini bukan metode statis.
Berlaku untuk
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Sumber:
- AsyncObservableExtensions.cs
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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte yang dipanggil untuk IAsyncObserver.OnNextAsync.
- 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
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
Disingkirkan jika fungsi filter aliran yang disediakan tidak cocok. Biasanya ini karena ini bukan metode statis.
Berlaku untuk
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Sumber:
- AsyncObservableExtensions.cs
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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte yang dipanggil untuk IAsyncObserver.OnNextAsync.
- 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
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
Disingkirkan jika fungsi filter aliran yang disediakan tidak cocok. Biasanya ini karena ini bukan metode statis.
Berlaku untuk
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Sumber:
- AsyncObservableExtensions.cs
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.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))Jenis parameter
- T
Jenis objek yang dihasilkan oleh yang dapat diamati.
Parameter
Objek Yang Dapat Diamati.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte yang dipanggil untuk IAsyncObserver.OnNextAsync.
- 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
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
Disingkirkan jika fungsi filter aliran yang disediakan tidak cocok. Biasanya ini karena ini bukan metode statis.