IAsyncBatchObservable<T>.SubscribeAsync Метод
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Перегрузки
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>
Асинхронный наблюдатель пакетной службы для подписки.
Возвращаемое значение
Обещание для 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
Последовательность потоков, используемая в качестве смещения для запуска подписки.
Возвращаемое значение
Обещание для StreamSubscriptionHandle, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.