IAsyncObservable<T>.SubscribeAsync Método
Definición
Importante
Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.
Sobrecargas
| SubscribeAsync(IAsyncObserver<T>) |
Suscríbase un consumidor a este observable. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String) |
Suscríbase un consumidor a este observable. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object) |
Suscríbase un consumidor a este observable. |
SubscribeAsync(IAsyncObserver<T>)
- Source:
- IAsyncObservable.cs
Suscríbase un consumidor a este observable.
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))Parámetros
- observer
- IAsyncObserver<T>
Observador asincrónico que se va a suscribir.
Devoluciones
Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.
Se aplica a
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)
Suscríbase un consumidor a este observable.
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))Parámetros
- observer
- IAsyncObserver<T>
Observador asincrónico que se va a suscribir.
- token
- StreamSequenceToken
Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.
- filterData
- String
Objeto de datos que se pasará al filtro.
Devoluciones
Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.
Se aplica a
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object)
- Source:
- IAsyncObservable.cs
Suscríbase un consumidor a este observable.
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))Parámetros
- observer
- IAsyncObserver<T>
Observador asincrónico que se va a suscribir.
- token
- StreamSequenceToken
Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.
- filterFunc
- StreamFilterPredicate
Filtro que se va a aplicar para esta suscripción
- filterData
- Object
Objeto de datos que se pasará a filterFunc. Normalmente, esto contendrá los parámetros requeridos por filterFunc para tomar la decisión de filtrado.
Devoluciones
Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre y cuando no se cancele explícitamente la suscripción.
Excepciones
Se produce si la función de filtro de flujo proporcionada no es adecuada. Normalmente, esto se debe a que no es un método estático.