AsyncObservableExtensions.SubscribeAsync 方法
定义
重要
一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。 对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。
重载
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)
- Source:
- AsyncObservableExtensions.cs
使用委托将使用者订阅到此可观测项。 此方法是 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
可观测对象生成的对象类型。
参数
可观测对象。
- 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
可观测对象生成的对象类型。
参数
可观测对象。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就一直处于活动状态。
例外
如果提供的流筛选器函数不适合，则引发。 通常是因为它不是静态方法。
适用于
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)
- Source:
- AsyncObservableExtensions.cs
使用委托将使用者订阅到此可观测项。 此方法是 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
可观测对象生成的对象类型。
参数
可观测对象。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就一直处于活动状态。
适用于
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)
- Source:
- AsyncObservableExtensions.cs
使用委托将使用者订阅到此可观测项。 此方法是 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
可观测对象生成的对象类型。
参数
可观测对象。
- 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
可观测对象生成的对象类型。
参数
可观测对象。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就一直处于活动状态。
例外
如果提供的流筛选器函数不适合，则引发。 通常是因为它不是静态方法。
适用于
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)
- Source:
- AsyncObservableExtensions.cs
使用委托将使用者订阅到此可观测项。 此方法是 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
可观测对象生成的对象类型。
参数
可观测对象。
- 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
可观测对象生成的对象类型。
参数
可观测对象。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就一直处于活动状态。
例外
如果提供的流筛选器函数不适合，则引发。 通常是因为它不是静态方法。
适用于
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Source:
- AsyncObservableExtensions.cs
使用委托将使用者订阅到此可观测项。 此方法是 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
可观测对象生成的对象类型。
参数
可观测对象。
- 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
可观测对象生成的对象类型。
参数
可观测对象。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就一直处于活动状态。
例外
如果提供的流筛选器函数不适合，则引发。 通常是因为它不是静态方法。
适用于
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Source:
- AsyncObservableExtensions.cs
使用委托将使用者订阅到此可观测项。 此方法是 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
可观测对象生成的对象类型。
参数
可观测对象。
- 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)
- Source:
- AsyncObservableExtensions.cs
使用委托将使用者订阅到此可观测项。 此方法是 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
可观测对象生成的对象类型。
参数
可观测对象。
- 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)
- Source:
- AsyncObservableExtensions.cs
使用委托将使用者订阅到此可观测项。 此方法是 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
可观测对象生成的对象类型。
参数
可观测对象。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
为 IAsyncObserver.OnNextAsync 调用的 Delegte。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
- filterFunc
- StreamFilterPredicate
要为此订阅应用的筛选器
- filterData
- Object
将传入 filterFunc 的数据对象。 这通常包含 filterFunc 做出筛选决策所需的任何参数。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就一直处于活动状态。
例外
如果提供的流筛选器函数不适合，则引发。 通常是因为它不是静态方法。