IAsyncBatchObservable<T> Interface

Definição

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacote:

Microsoft.Orleans.Streaming v8.2.0

Essa interface generaliza a interface IAsyncObserver para permitir a produção e o consumo de lotes de itens.

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

public interface IAsyncBatchObservable<T>

type IAsyncBatchObservable<'T> = interface

Public Interface IAsyncBatchObservable(Of T)

Parâmetros de tipo

T

O tipo de objeto consumido pelo observador.

Derivado

Orleans.Streams.IAsyncStream<T>

Métodos

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

Métodos de Extensão

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)	Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para o IAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos de manipulador em vez de exigir uma instância de IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)	Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para o IAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos de manipulador em vez de exigir uma instância de IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)	Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para o IAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos de manipulador em vez de exigir uma instância de IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)	Assine um consumidor para esse observável usando delegados. Esse método é um auxiliar para o IAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos de manipulador em vez de exigir uma instância de IAsyncBatchObserver.