StreamSubscriptionHandleExtensions.ResumeAsync 方法
定义
重要
一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。 对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。
重载
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)
如果提供的流筛选器函数不适合，则引发。 通常，这是因为这不是静态方法。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token = default);static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
- handle
- StreamSubscriptionHandle<T>
订阅句柄。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。
适用于
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)
如果提供的流筛选器函数不适合，则引发。 通常，这是因为这不是静态方法。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token = default);static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
- handle
- StreamSubscriptionHandle<T>
订阅句柄。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。
适用于
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)
使用委托恢复流消耗。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 实例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token = default);static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
- handle
- StreamSubscriptionHandle<T>
订阅句柄。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。
适用于
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)
使用委托恢复流消耗。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 实例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
- handle
- StreamSubscriptionHandle<T>
订阅句柄。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。
适用于
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)
使用委托恢复流消耗。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token = default);static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'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 ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
- handle
- StreamSubscriptionHandle<T>
订阅句柄。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。
适用于
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)
使用委托恢复流消耗。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'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 ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
- handle
- StreamSubscriptionHandle<T>
订阅句柄。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。
适用于
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)
使用委托恢复流消耗。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 实例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, 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 ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
- handle
- StreamSubscriptionHandle<T>
订阅句柄。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。
适用于
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)
使用委托恢复流消耗。 此方法是 StreamSubscriptionHandle.ResumeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, 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 = default);static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'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 ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
- handle
- StreamSubscriptionHandle<T>
订阅句柄。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
为 IAsyncObserver.OnNextAsync 调用的委托。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。