StreamSubscriptionHandle<T>.ResumeAsync 方法

定义

重载

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

要用作从其启动订阅的偏移量的流序列。

返回

新的流订阅句柄。

适用于