AsyncObservableExtensions.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<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncObserver. |
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)
- Source:
- AsyncObservableExtensions.cs
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado al que se llama para IAsyncObserver.OnNextAsync.
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<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado al que se llama para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.
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.
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.
Se aplica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)
- Source:
- AsyncObservableExtensions.cs
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado al que se llama para IAsyncObserver.OnNextAsync.
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<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)
- Source:
- AsyncObservableExtensions.cs
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado al que se llama para IAsyncObserver.OnNextAsync.
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<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado al que se llama para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.
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.
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.
Se aplica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)
- Source:
- AsyncObservableExtensions.cs
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado al que se llama para IAsyncObserver.OnNextAsync.
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<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado al que se llama para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.
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.
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.
Se aplica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Source:
- AsyncObservableExtensions.cs
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte al que se llama para IAsyncObserver.OnNextAsync.
- 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.
Se aplica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado al que se llama para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.
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.
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.
Se aplica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Source:
- AsyncObservableExtensions.cs
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte al que se llama para IAsyncObserver.OnNextAsync.
- 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.
Se aplica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Source:
- AsyncObservableExtensions.cs
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte al que se llama para IAsyncObserver.OnNextAsync.
- 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.
Se aplica a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Source:
- AsyncObservableExtensions.cs
Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))Parámetros de tipo
- T
Tipo de objeto generado por el observable.
Parámetros
Objeto Observable.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte al que se llama para IAsyncObserver.OnNextAsync.
- 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.