IAsyncBatchObservable<T> Интерфейс

Определение

Пространство имен:

Orleans.Streams

Сборка:

Orleans.Streaming.dll

Пакет:

Microsoft.Orleans.Streaming v8.2.0

Этот интерфейс обобщает интерфейс IAsyncObserver, чтобы разрешить производство и потребление пакетов элементов.

Обратите внимание, что этот интерфейс реализуется потребителями элементов и вызывается (используется) производителями элементов. Это означает, что конечная точка потребителя потока реализует этот интерфейс.

public interface IAsyncBatchObservable<T>

type IAsyncBatchObservable<'T> = interface

Public Interface IAsyncBatchObservable(Of T)

Параметры типа

T

Тип объекта, потребляемого наблюдателем.

Производный

Orleans.Streams.IAsyncStream<T>

Методы

SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Подпишитесь на потребителя на этот пакет, который можно наблюдать.
SubscribeAsync(IAsyncBatchObserver<T>)	Подпишитесь на потребителя на этот пакет, который можно наблюдать.

Методы расширения

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)	Подпишите потребителя на это наблюдаемое с помощью делегатов. Этот метод является вспомогательным методом для IAsyncBatchObservable.SubscribeAsync, позволяя классу подписки встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)	Подпишите потребителя на это наблюдаемое с помощью делегатов. Этот метод является вспомогательным методом для IAsyncBatchObservable.SubscribeAsync, позволяя классу подписки встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)	Подпишите потребителя на это наблюдаемое с помощью делегатов. Этот метод является вспомогательным методом для IAsyncBatchObservable.SubscribeAsync, позволяя классу подписки встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)	Подпишите потребителя на это наблюдаемое с помощью делегатов. Этот метод является вспомогательным методом для IAsyncBatchObservable.SubscribeAsync, позволяя классу подписки встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncBatchObserver.