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

Определение

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

Orleans.Streams

Сборка:

Orleans.Streaming.dll

Пакет:

Microsoft.Orleans.Streaming v8.1.0

Этот интерфейс обобщает стандартный интерфейс IObserveable .NET, чтобы разрешить асинхронное использование элементов. Асинхронный здесь означает, что потребитель может асинхронно обрабатывать элементы и сообщать о завершении элемента производителю, завершив возвращенную задачу.

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

public interface IAsyncObservable<T>

type IAsyncObservable<'T> = interface

Public Interface IAsyncObservable(Of T)

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

T

Тип объекта, создаваемого наблюдаемым объектом.

Производный

Orleans.Streams.IAsyncStream<T>

Методы

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

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

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