Поделиться через

IAsyncBatchObservable<T>.SubscribeAsync Метод

  • Ссылка

Определение

Пространство имен:
Orleans.Streams
Сборка:
Orleans.Core.Abstractions.dll
Сборка:
Orleans.Streaming.dll
Пакет:
Microsoft.Orleans.Core.Abstractions v2.4.5
Пакет:
Microsoft.Orleans.Core.Abstractions v3.6.5
Пакет:
Microsoft.Orleans.Streaming v7.2.5
Пакет:
Microsoft.Orleans.Streaming v8.0.0
Пакет:
Microsoft.Orleans.Streaming v8.1.0

Перегрузки

SubscribeAsync(IAsyncBatchObserver<T>)

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

Подпишите потребителя на этот пакет, доступный для наблюдения.

SubscribeAsync(IAsyncBatchObserver<T>)

Исходный код:
IAsyncBatchObservable.cs

Подпишите потребителя на этот пакет, доступный для наблюдения.

public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer);
abstract member SubscribeAsync : Orleans.Streams.IAsyncBatchObserver<'T> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
Public Function SubscribeAsync (observer As IAsyncBatchObserver(Of T)) As Task(Of StreamSubscriptionHandle(Of T))

Параметры

observer
IAsyncBatchObserver<T>

Асинхронный наблюдатель пакетной службы для подписки.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Обещание для StreamSubscriptionHandle, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.

Применяется к

SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

Исходный код:
IAsyncBatchObservable.cs

Подпишите потребителя на этот пакет, доступный для наблюдения.

public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer, Orleans.Streams.StreamSequenceToken token);
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer, Orleans.Streams.StreamSequenceToken? token);
abstract member SubscribeAsync : Orleans.Streams.IAsyncBatchObserver<'T> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
Public Function SubscribeAsync (observer As IAsyncBatchObserver(Of T), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

Параметры

observer
IAsyncBatchObserver<T>

Асинхронный наблюдатель пакетной службы для подписки.

token
StreamSequenceToken

Последовательность потоков, используемая в качестве смещения для запуска подписки.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Обещание для StreamSubscriptionHandle, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.

Применяется к