次の方法で共有


StreamSubscriptionHandle<T>.ResumeAsync メソッド

定義

オーバーロード

ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

サブスクリプションからストリームへのバッチ消費量を再開します。

ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)

サブスクリプションからストリームへの消費を再開しました。

ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

ソース:
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)

ソース:
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

サブスクリプションの開始元のオフセットとして使用されるストリーム シーケンス。

戻り値

新しいストリーム サブスクリプション ハンドル。

適用対象