AsyncObservableExtensions.SubscribeAsync 方法
定義
重要
部分資訊涉及發行前產品，在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊，不做任何明確或隱含的瑕疵擔保。
多載
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)
使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task)) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的型別。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱，訂用帳戶就會保持作用中狀態。
適用於
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)
使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的型別。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱，訂用帳戶就會保持作用中狀態。
例外狀況
如果提供的資料流程篩選函式不適合，則會擲回 。 這通常是因為它不是靜態方法。
適用於
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)
使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task)) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的型別。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱，訂用帳戶就會保持作用中狀態。
適用於
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)
使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的型別。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱，訂用帳戶就會保持作用中狀態。
適用於
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)
使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的型別。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂用帳戶的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱，訂用帳戶就會保持作用中狀態。
例外狀況
如果提供的資料流程篩選函式不適合，則會擲回 。 這通常是因為它不是靜態方法。
適用於
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)
使用委派向取用者訂閱此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的類型。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
傳回
代表訂閱的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱，訂用帳戶就會保持作用中狀態。
適用於
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)
使用委派向取用者訂閱此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的類型。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂閱的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱，訂用帳戶就會保持作用中狀態。
例外狀況
如果提供的資料流程篩選函式不適合，則會擲回 。 這通常是因為它不是靜態方法。
適用於
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
使用委派向取用者訂閱此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的類型。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的 Delegte。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
- filterFunc
- StreamFilterPredicate
要套用此訂用帳戶的篩選
- filterData
- Object
將傳入 filterFunc 的資料物件。 這通常會包含 filterFunc 所需的任何參數，以做出篩選決策。
傳回
代表訂閱的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要未明確取消訂閱，訂用帳戶就會保持作用中狀態。
例外狀況
如果提供的資料流程篩選函式不適合，則會擲回 。 這通常是因為它不是靜態方法。
適用於
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)
使用委派向取用者訂閱此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的類型。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的委派。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
傳回
代表訂閱的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要訂閱未明確取消訂閱，訂用帳戶就會保持作用中狀態。
例外狀況
如果提供的資料流程篩選函式不適合，則會擲回 。 這通常是因為它不是靜態方法。
適用於
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
使用委派向取用者訂閱此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的類型。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的 Delegte。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
- filterFunc
- StreamFilterPredicate
要套用此訂用帳戶的篩選
- filterData
- Object
將傳入 filterFunc 的資料物件。 這通常會包含 filterFunc 所需的任何參數，以做出篩選決策。
傳回
代表訂閱的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要未明確取消訂閱，訂用帳戶就會保持作用中狀態。
例外狀況
如果提供的資料流程篩選函式不適合，則會擲回 。 這通常是因為它不是靜態方法。
適用於
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
使用委派向取用者訂閱此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的類型。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的 Delegte。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
- filterFunc
- StreamFilterPredicate
要套用此訂用帳戶的篩選
- filterData
- Object
將傳入 filterFunc 的資料物件。 這通常會包含 filterFunc 所需的任何參數，以做出篩選決策。
傳回
代表訂閱的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要未明確取消訂閱，訂用帳戶就會保持作用中狀態。
例外狀況
如果提供的資料流程篩選函式不適合，則會擲回 。 這通常是因為它不是靜態方法。
適用於
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
使用委派向取用者訂閱此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))類型參數
- T
可觀察物件所產生的類型。
參數
Observable 物件。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
針對 IAsyncObserver.OnNextAsync 呼叫的 Delegte。
- token
- StreamSequenceToken
要作為起始訂閱之位移的資料流程序列。
- filterFunc
- StreamFilterPredicate
要套用此訂用帳戶的篩選
- filterData
- Object
將傳入 filterFunc 的資料物件。 這通常會包含 filterFunc 所需的任何參數，以做出篩選決策。
傳回
代表訂閱的 StreamSubscriptionHandle 承諾。 取用者可以使用這個控制碼取消訂閱。 只要未明確取消訂閱，訂用帳戶就會保持作用中狀態。
例外狀況
如果提供的資料流程篩選函式不適合，則會擲回 。 這通常是因為它不是靜態方法。