IAsyncObserver<T> Interface

Definição

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacote:

Microsoft.Orleans.Streaming v8.2.0

Essa interface generaliza a interface IObserver padrão do .NET para permitir a produção assíncrona 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 IAsyncObserver<in T>

type IAsyncObserver<'T> = interface

Public Interface IAsyncObserver(Of In T)

Parâmetros de tipo

T

O tipo de objeto consumido pelo observador.

Este parâmetro de tipo é contravariante. Isso significa que é possível usar o tipo especificado ou qualquer tipo menos derivado. Para obter mais informações sobre covariância e contravariância, consulte Covariância e contravariância em genéricos.

Derivado

Orleans.Streams.IAsyncBatchProducer<T>

Orleans.Streams.IAsyncStream<T>

Métodos

OnCompletedAsync()	Notifica o consumidor de que o fluxo foi concluído. A Tarefa retornada desse método deve ser concluída quando o consumidor terminar de processar o fechamento do fluxo.
OnErrorAsync(Exception)	Notifica o consumidor de que o fluxo teve um erro. A Tarefa retornada desse método deve ser concluída quando o consumidor terminar de processar o fechamento do fluxo.
OnNextAsync(T, StreamSequenceToken)	Passa o próximo item para o consumidor. A Tarefa retornada desse método deve ser concluída quando o processamento do item tiver sido processado suficientemente pelo consumidor para atender a quaisquer garantias comportamentais. Quando o consumidor é o (ponto de extremidade do produtor de) um fluxo, a Tarefa é concluída quando a implementação do fluxo aceita a responsabilidade pelo item e tem a garantia de cumprir suas garantias de entrega. Por exemplo, um fluxo baseado em uma fila durável concluiria a Tarefa quando o item tiver sido salvo de maneira durável. Um fluxo que fornece melhor esforço no máximo uma vez que a entrega retornaria uma Tarefa que já está concluída. Quando o produtor for o (ponto de extremidade do consumidor de) um fluxo, a Tarefa deverá ser concluída pelo código do consumidor quando tiver aceitado a responsabilidade pelo item. Em particular, se o provedor de fluxo garantir pelo menos uma entrega, o item não deverá ser considerado entregue até que a Tarefa retornada pelo consumidor seja concluída.