IAsyncObservable<T>.SubscribeAsync Метод
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Перегрузки
| SubscribeAsync(IAsyncObserver<T>) |
Подпишите потребителя на этот наблюдаемый объект. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String) |
Подпишите потребителя на этот наблюдаемый объект. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object) |
Подпишите потребителя на этот наблюдаемый объект. |
SubscribeAsync(IAsyncObserver<T>)
- Исходный код:
- IAsyncObservable.cs
Подпишите потребителя на этот наблюдаемый объект.
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T)) As Task(Of StreamSubscriptionHandle(Of T))Параметры
- observer
- IAsyncObserver<T>
Асинхронный наблюдатель для подписки.
Возвращаемое значение
Обещание для StreamSubscriptionHandle, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не отменена явным образом.
Применяется к
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)
Подпишите потребителя на этот наблюдаемый объект.
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken? token, string? filterData = default);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken * string -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T), token As StreamSequenceToken, Optional filterData As String = Nothing) As Task(Of StreamSubscriptionHandle(Of T))Параметры
- observer
- IAsyncObserver<T>
Асинхронный наблюдатель для подписки.
- token
- StreamSequenceToken
Последовательность потоков, используемая в качестве смещения для запуска подписки.
- filterData
- String
Объект данных, который будет передан в фильтр.
Возвращаемое значение
Обещание для StreamSubscriptionHandle, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не отменена явным образом.
Применяется к
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object)
- Исходный код:
- IAsyncObservable.cs
Подпишите потребителя на этот наблюдаемый объект.
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))Параметры
- observer
- IAsyncObserver<T>
Асинхронный наблюдатель для подписки.
- token
- StreamSequenceToken
Последовательность потоков, используемая в качестве смещения для запуска подписки.
- filterFunc
- StreamFilterPredicate
Фильтр, применяемый к этой подписке
- filterData
- Object
Объект данных, который будет передан в filterFunc. Обычно он содержит все параметры, необходимые filterFunc для принятия решения о фильтрации.
Возвращаемое значение
Обещание для StreamSubscriptionHandle, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не отменена явным образом.
Исключения
Возникает, если предоставленная функция фильтра потока не подходит. Обычно это связано с тем, что это не статический метод.