StreamSubscriptionHandleExtensions.ResumeAsync メソッド

定義

オーバーロード

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)

指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)

デリゲートを使用してストリームの使用を再開します。 このメソッドは StreamSubscriptionHandle.ResumeAsync のヘルパーであり、サブスクライブ しているクラスが IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できるようにします。

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)

デリゲートを使用してストリームの使用を再開します。 このメソッドは StreamSubscriptionHandle.ResumeAsync のヘルパーであり、サブスクライブ しているクラスが IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できるようにします。

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

デリゲートを使用してストリームの使用を再開します。 このメソッドは StreamSubscriptionHandle.ResumeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

デリゲートを使用してストリームの使用を再開します。 このメソッドは StreamSubscriptionHandle.ResumeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

デリゲートを使用してストリームの使用を再開します。 このメソッドは StreamSubscriptionHandle.ResumeAsync のヘルパーであり、サブスクライブ しているクラスが IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できるようにします。

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

デリゲートを使用してストリームの使用を再開します。 このメソッドは StreamSubscriptionHandle.ResumeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)

ソース:
StreamSubscriptionHandleExtensions.cs

指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。

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

observable によって生成されるオブジェクトの型。

パラメーター

handle
StreamSubscriptionHandle<T>

サブスクリプション ハンドル。

onNextAsync
Func<IList<SequentialItem<T>>,Task>

IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。

token
StreamSequenceToken

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

戻り値

サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。

適用対象

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

ソース:
StreamSubscriptionHandleExtensions.cs

指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。

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

observable によって生成されるオブジェクトの型。

パラメーター

handle
StreamSubscriptionHandle<T>

サブスクリプション ハンドル。

onNextAsync
Func<T,StreamSequenceToken,Task>

IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。

token
StreamSequenceToken

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

戻り値

サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。

適用対象

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)

ソース:
StreamSubscriptionHandleExtensions.cs

デリゲートを使用してストリームの使用を再開します。 このメソッドは 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

observable によって生成されるオブジェクトの型。

パラメーター

handle
StreamSubscriptionHandle<T>

サブスクリプション ハンドル。

onNextAsync
Func<IList<SequentialItem<T>>,Task>

IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。

onErrorAsync
Func<Exception,Task>

IAsyncObserver.OnErrorAsync に対して呼び出されるデリゲート。

token
StreamSequenceToken

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

戻り値

サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。

適用対象

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)

ソース:
StreamSubscriptionHandleExtensions.cs

デリゲートを使用してストリームの使用を再開します。 このメソッドは 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

observable によって生成されるオブジェクトの型。

パラメーター

handle
StreamSubscriptionHandle<T>

サブスクリプション ハンドル。

onNextAsync
Func<IList<SequentialItem<T>>,Task>

IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。

onCompletedAsync
Func<Task>

IAsyncObserver.OnCompletedAsync に対して呼び出されるデリゲート。

token
StreamSequenceToken

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

戻り値

サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。

適用対象

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

ソース:
StreamSubscriptionHandleExtensions.cs

デリゲートを使用してストリームの使用を再開します。 このメソッドは 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

observable によって生成されるオブジェクトの型。

パラメーター

handle
StreamSubscriptionHandle<T>

サブスクリプション ハンドル。

onNextAsync
Func<T,StreamSequenceToken,Task>

IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。

onErrorAsync
Func<Exception,Task>

IAsyncObserver.OnErrorAsync に対して呼び出されるデリゲート。

token
StreamSequenceToken

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

戻り値

サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。

適用対象

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

ソース:
StreamSubscriptionHandleExtensions.cs

デリゲートを使用してストリームの使用を再開します。 このメソッドは 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

observable によって生成されるオブジェクトの型。

パラメーター

handle
StreamSubscriptionHandle<T>

サブスクリプション ハンドル。

onNextAsync
Func<T,StreamSequenceToken,Task>

IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。

onCompletedAsync
Func<Task>

IAsyncObserver.OnCompletedAsync に対して呼び出されるデリゲート。

token
StreamSequenceToken

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

戻り値

サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。

適用対象

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

ソース:
StreamSubscriptionHandleExtensions.cs

デリゲートを使用してストリームの使用を再開します。 このメソッドは 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 に対して呼び出されるデリゲート。

onErrorAsync
Func<Exception,Task>

IAsyncObserver.OnErrorAsync に対して呼び出されるデリゲート。

onCompletedAsync
Func<Task>

IAsyncObserver.OnCompletedAsync に対して呼び出されるデリゲート。

token
StreamSequenceToken

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

戻り値

サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。

適用対象

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

ソース:
StreamSubscriptionHandleExtensions.cs

デリゲートを使用してストリームの使用を再開します。 このメソッドは 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 に対して呼び出されるデリゲート。

onErrorAsync
Func<Exception,Task>

IAsyncObserver.OnErrorAsync に対して呼び出されるデリゲート。

onCompletedAsync
Func<Task>

IAsyncObserver.OnCompletedAsync に対して呼び出されるデリゲート。

token
StreamSequenceToken

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

戻り値

サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。

適用対象