IAsyncObservable<T>.SubscribeAsync Metodo
Definizione
Importante
Alcune informazioni sono relative alla release non definitiva del prodotto, che potrebbe subire modifiche significative prima della release definitiva. Microsoft non riconosce alcuna garanzia, espressa o implicita, in merito alle informazioni qui fornite.
Overload
| SubscribeAsync(IAsyncObserver<T>) |
Sottoscrivere un consumer a questo oggetto osservabile. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String) |
Sottoscrivere un consumer a questo oggetto osservabile. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object) |
Sottoscrivere un consumer a questo oggetto osservabile. |
SubscribeAsync(IAsyncObserver<T>)
- Origine:
- IAsyncObservable.cs
Sottoscrivere un consumer a questo oggetto osservabile.
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))Parametri
- observer
- IAsyncObserver<T>
Osservatore asincrono da sottoscrivere.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.
Si applica a
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)
Sottoscrivere un consumer a questo oggetto osservabile.
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))Parametri
- observer
- IAsyncObserver<T>
Osservatore asincrono da sottoscrivere.
- token
- StreamSequenceToken
Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione.
- filterData
- String
Oggetto dati che verrà passato al filtro.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.
Si applica a
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object)
- Origine:
- IAsyncObservable.cs
Sottoscrivere un consumer a questo oggetto osservabile.
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))Parametri
- observer
- IAsyncObserver<T>
Osservatore asincrono da sottoscrivere.
- token
- StreamSequenceToken
Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione.
- filterFunc
- StreamFilterPredicate
Filtro da applicare per questa sottoscrizione
- filterData
- Object
Oggetto dati che verrà passato al filterFunc. Questo in genere conterrà i parametri richiesti dal filterFunc per prendere una decisione di filtro.
Restituisce
Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata esplicitamente la sottoscrizione.
Eccezioni
Generata se la funzione di filtro del flusso fornita non è adatta. In genere ciò è dovuto al fatto che non è un metodo statico.