IAsyncObservable<T> Interface

Definição

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacote:

Microsoft.Orleans.Streaming v8.1.0

Essa interface generaliza a interface IObserveable padrão do .NET para permitir o consumo assíncrono de itens. Assíncrono aqui significa que o consumidor pode processar itens de forma assíncrona e sinalizar a conclusão do item para o produtor concluindo a Tarefa retornada.

Observe que essa interface é invocada (usada) pelos consumidores de itens e implementada pelos produtores de itens. Isso significa que o ponto de extremidade do produtor de um fluxo implementa essa interface.

public interface IAsyncObservable<T>

type IAsyncObservable<'T> = interface

Public Interface IAsyncObservable(Of T)

Parâmetros de tipo

T

O tipo de objeto produzido pelo observável.

Derivado

Orleans.Streams.IAsyncStream<T>

Métodos

SubscribeAsync(IAsyncObserver<T>)	Assine um consumidor para este observável.
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	Assine um consumidor para este observável.

Métodos de Extensão

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<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<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<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.