IAsyncStream<T> Interface

Definição

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacote:

Microsoft.Orleans.Streaming v8.2.0

Essa interface representa um objeto que serve como um encontro distribuído entre produtores e consumidores. Ele é semelhante a uma Estrutura Subject Reativa e implementa IObserver nem IObservable interfaces.

public interface IAsyncStream<T> : IComparable<Orleans.Streams.IAsyncStream<T>>, IEquatable<Orleans.Streams.IAsyncStream<T>>, Orleans.Streams.IAsyncBatchObservable<T>, Orleans.Streams.IAsyncBatchProducer<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IAsyncStream

type IAsyncStream<'T> = interface
    interface IAsyncStream
    interface IEquatable<IAsyncStream<'T>>
    interface IComparable<IAsyncStream<'T>>
    interface IAsyncObservable<'T>
    interface IAsyncBatchObservable<'T>
    interface IAsyncBatchProducer<'T>
    interface IAsyncObserver<'T>

Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObservable(Of T), IAsyncBatchProducer(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IAsyncStream, IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T))

Parâmetros de tipo

T

O tipo de objeto que flui pelo fluxo.

Implementações

IAsyncObservable<T> IAsyncObserver<T> IComparable<IAsyncStream<T>> IEquatable<IAsyncStream<T>> IAsyncBatchObservable<T> IAsyncBatchProducer<T> IAsyncStream

Propriedades

StreamId

Obtém o identificador de fluxo. (Herdado de IAsyncStream)

Métodos

GetAllSubscriptionHandles()	Recupera uma lista de todas as assinaturas ativas criadas pelo chamador para esse fluxo.
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. (Herdado de IAsyncObserver<T>)
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. (Herdado de IAsyncObserver<T>)
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. (Herdado de IAsyncObserver<T>)
OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken)	Passa o próximo lote de itens para o consumidor. A Tarefa retornada desse método deve ser concluída quando todos os itens no lote tiverem sido processados suficientemente pelo consumidor para atender a quaisquer garantias comportamentais. Ou seja, a semântica da Tarefa retornada é a mesma que para OnNextAsync(T, StreamSequenceToken), estendida para todos os itens no lote. (Herdado de IAsyncBatchProducer<T>)
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Assine um consumidor para este lote observável. (Herdado de IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncBatchObserver<T>)	Assine um consumidor para este lote observável. (Herdado de IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	Assine um consumidor para este observável. (Herdado de IAsyncObservable<T>)
SubscribeAsync(IAsyncObserver<T>)	Assine um consumidor para este observável. (Herdado de IAsyncObservable<T>)

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