AsyncObservableExtensions.SubscribeAsync Método
Definição
Importante
Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.
Sobrecargas
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver. |
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)
- Origem:
- AsyncObservableExtensions.cs
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado chamado para IAsyncObserver.OnNextAsync.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não estiver explicitamente inscrita.
Aplica-se a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado chamado para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
A sequência de fluxo a ser usada como um deslocamento para iniciar a assinatura.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não estiver explicitamente inscrita.
Exceções
Gerada se a função de filtro de fluxo fornecida não for adequada. Normalmente, isso ocorre porque não é um método estático.
Aplica-se a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)
- Origem:
- AsyncObservableExtensions.cs
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado chamado para IAsyncObserver.OnNextAsync.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não estiver explicitamente inscrita.
Aplica-se a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)
- Origem:
- AsyncObservableExtensions.cs
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado chamado para IAsyncObserver.OnNextAsync.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não estiver explicitamente inscrita.
Aplica-se a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado chamado para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
A sequência de fluxo a ser usada como um deslocamento para iniciar a assinatura.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não estiver explicitamente inscrita.
Exceções
Gerada se a função de filtro de fluxo fornecida não for adequada. Normalmente, isso ocorre porque não é um método estático.
Aplica-se a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)
- Origem:
- AsyncObservableExtensions.cs
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado chamado para IAsyncObserver.OnNextAsync.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não estiver explicitamente inscrita.
Aplica-se a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado chamado para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
A sequência de fluxo a ser usada como um deslocamento para iniciar a assinatura.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não estiver explicitamente inscrita.
Exceções
Gerada se a função de filtro de fluxo fornecida não for adequada. Normalmente, isso ocorre porque não é um método estático.
Aplica-se a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Origem:
- AsyncObservableExtensions.cs
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte que é chamado para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
A sequência de fluxo a ser usada como um deslocamento para iniciar a assinatura.
- filterFunc
- StreamFilterPredicate
Filtro a ser aplicado para esta assinatura
- filterData
- Object
Objeto de dados que será passado para o filterFunc. Isso geralmente conterá todos os paramaters exigidos pelo filterFunc para tomar sua decisão de filtragem.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não for explicitamente desassinada.
Exceções
Gerada se a função de filtro de fluxo fornecida não for adequada. Normalmente, isso ocorre porque não é um método estático.
Aplica-se a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegado chamado para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
A sequência de fluxo a ser usada como um deslocamento para iniciar a assinatura.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não estiver explicitamente inscrita.
Exceções
Gerada se a função de filtro de fluxo fornecida não for adequada. Normalmente, isso ocorre porque não é um método estático.
Aplica-se a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Origem:
- AsyncObservableExtensions.cs
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte que é chamado para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
A sequência de fluxo a ser usada como um deslocamento para iniciar a assinatura.
- filterFunc
- StreamFilterPredicate
Filtro a ser aplicado para esta assinatura
- filterData
- Object
Objeto de dados que será passado para o filterFunc. Isso geralmente conterá todos os paramaters exigidos pelo filterFunc para tomar sua decisão de filtragem.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não for explicitamente desassinada.
Exceções
Gerada se a função de filtro de fluxo fornecida não for adequada. Normalmente, isso ocorre porque não é um método estático.
Aplica-se a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Origem:
- AsyncObservableExtensions.cs
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte que é chamado para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
A sequência de fluxo a ser usada como um deslocamento para iniciar a assinatura.
- filterFunc
- StreamFilterPredicate
Filtro a ser aplicado para esta assinatura
- filterData
- Object
Objeto de dados que será passado para o filterFunc. Isso geralmente conterá todos os paramaters exigidos pelo filterFunc para tomar sua decisão de filtragem.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não for explicitamente desassinada.
Exceções
Gerada se a função de filtro de fluxo fornecida não for adequada. Normalmente, isso ocorre porque não é um método estático.
Aplica-se a
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Origem:
- AsyncObservableExtensions.cs
Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para iAsyncObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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
O tipo de objeto produzido pelo observável.
Parâmetros
O objeto Observável.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte que é chamado para IAsyncObserver.OnNextAsync.
- token
- StreamSequenceToken
A sequência de fluxo a ser usada como um deslocamento para iniciar a assinatura.
- filterFunc
- StreamFilterPredicate
Filtro a ser aplicado para esta assinatura
- filterData
- Object
Objeto de dados que será passado para o filterFunc. Isso geralmente conterá todos os paramaters exigidos pelo filterFunc para tomar sua decisão de filtragem.
Retornos
Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa enquanto não for explicitamente desassinada.
Exceções
Gerada se a função de filtro de fluxo fornecida não for adequada. Normalmente, isso ocorre porque não é um método estático.