StreamSubscriptionHandle<T>.ResumeAsync 方法
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
重载
ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken) |
从订阅恢复批量使用到流。 |
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken) |
从订阅恢复到流的消耗。 |
ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)
- Source:
- StreamSubscriptionHandle.cs
从订阅恢复批量使用到流。
public abstract System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer, Orleans.Streams.StreamSequenceToken token = default);
abstract member ResumeAsync : Orleans.Streams.IAsyncBatchObserver<'T> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
Public MustOverride Function ResumeAsync (observer As IAsyncBatchObserver(Of T), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))
参数
- observer
- IAsyncBatchObserver<T>
batcj bserver 对象。
- token
- StreamSequenceToken
要用作从其启动订阅的偏移量的流序列。
返回
新的流订阅句柄。
适用于
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)
- Source:
- StreamSubscriptionHandle.cs
从订阅恢复到流的消耗。
public abstract System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync (Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken token = default);
abstract member ResumeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
Public MustOverride Function ResumeAsync (observer As IAsyncObserver(Of T), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))
参数
- observer
- IAsyncObserver<T>
观察者对象。
- token
- StreamSequenceToken
要用作从其启动订阅的偏移量的流序列。
返回
新的流订阅句柄。