IAsyncObservable<T>.SubscribeAsync 方法
定义
重要
一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。 对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。
重载
SubscribeAsync(IAsyncObserver<T>)
- Source:
- 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)
- Source:
- 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 的承诺。 使用者可以通过使用此句柄取消订阅。 只要未显式取消订阅，订阅就保持活动状态。
例外
如果提供的流筛选器函数不适用，则引发。 这通常是因为它不是静态方法。