IAsyncObservable<T>.SubscribeAsync 方法
定義
重要
部分資訊涉及發行前產品，在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊，不做任何明確或隱含的瑕疵擔保。
多載
SubscribeAsync(IAsyncObserver<T>)
訂閱取用者以取得此可觀察。
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)
訂閱取用者以取得此可觀察。
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 承諾。 取用者可以使用這個控制碼取消訂閱。 只要未明確取消訂閱，訂用帳戶就會保持作用中狀態。
例外狀況
如果提供的資料流程篩選函式不適合，則會擲回 。 這通常是因為它不是靜態方法。