IAsyncObservable<T>.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(IAsyncObserver<T>) |
Assine um consumidor para este observável. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String) |
Assine um consumidor para este observável. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object) |
Assine um consumidor para este observável. |
SubscribeAsync(IAsyncObserver<T>)
- Origem:
- IAsyncObservable.cs
Assine um consumidor para este observável.
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>
O observador assíncrono a ser assinado.
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(IAsyncObserver<T>, StreamSequenceToken, String)
Assine um consumidor para este observável.
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>
O observador assíncrono a ser assinado.
- token
- StreamSequenceToken
A sequência de fluxo a ser usada como um deslocamento para iniciar a assinatura.
- filterData
- String
Objeto de dados que será passado para o filtro.
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(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object)
- Origem:
- IAsyncObservable.cs
Assine um consumidor para este observável.
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>
O observador assíncrono a ser assinado.
- 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.