AsyncObservableExtensions.SubscribeAsync メソッド

リファレンス

定義

名前空間:: Orleans.Streams

アセンブリ:: Orleans.dll

アセンブリ:: Orleans.Core.Abstractions.dll

アセンブリ:: Orleans.Streaming.dll

パッケージ:: Microsoft.Orleans.Core v1.5.10

パッケージ:: Microsoft.Orleans.Core.Abstractions v2.4.5

パッケージ:: Microsoft.Orleans.Core.Abstractions v3.6.5

パッケージ:: Microsoft.Orleans.Streaming v7.2.5

パッケージ:: Microsoft.Orleans.Streaming v8.0.0

パッケージ:: Microsoft.Orleans.Streaming v8.1.0

パッケージ:: Microsoft.Orleans.Streaming v8.2.0

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

オーバーロード

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)	デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)

ソース:: AsyncObservableExtensions.cs

デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブクラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラーメソッドをインライン化できます。

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task)) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

監視可能オブジェクトによって生成されるオブジェクトの型。

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

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

戻り値

Task<StreamSubscriptionHandle<T>>

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

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

監視可能オブジェクトによって生成されるオブジェクトの型。

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

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

token: StreamSequenceToken

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

戻り値

Task<StreamSubscriptionHandle<T>>

例外

ArgumentException

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

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)

ソース:: AsyncObservableExtensions.cs

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task)) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

監視可能オブジェクトによって生成されるオブジェクトの型。

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

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

onErrorAsync: Func<Exception,Task>

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

戻り値

Task<StreamSubscriptionHandle<T>>

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)

ソース:: AsyncObservableExtensions.cs

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

監視可能オブジェクトによって生成されるオブジェクトの型。

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

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

onCompletedAsync: Func<Task>

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

戻り値

Task<StreamSubscriptionHandle<T>>

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'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 SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

監視可能オブジェクトによって生成されるオブジェクトの型。

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

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

onErrorAsync: Func<Exception,Task>

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

token: StreamSequenceToken

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

戻り値

Task<StreamSubscriptionHandle<T>>

例外

ArgumentException

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

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)

ソース:: AsyncObservableExtensions.cs

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

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

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

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

onErrorAsync: Func<Exception,Task>

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

onCompletedAsync: Func<Task>

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

戻り値

Task<StreamSubscriptionHandle<T>>

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

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'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 SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

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

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

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

onCompletedAsync: Func<Task>

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

token: StreamSequenceToken

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

戻り値

Task<StreamSubscriptionHandle<T>>

例外

ArgumentException

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

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

ソース:: AsyncObservableExtensions.cs

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

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

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

IAsyncObserver.OnNextAsync に対して呼び出される Delegte。

token: StreamSequenceToken

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

filterFunc: StreamFilterPredicate

このサブスクリプションに適用するフィルター

filterData: Object

filterFunc に渡されるデータオブジェクト。これには通常、フィルター処理の決定を行うために filterFunc に必要なパラメーターが含まれます。

戻り値

Task<StreamSubscriptionHandle<T>>

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

例外

ArgumentException

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

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, 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);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'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 SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

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

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

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

onErrorAsync: Func<Exception,Task>

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

onCompletedAsync: Func<Task>

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

token: StreamSequenceToken

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

戻り値

Task<StreamSubscriptionHandle<T>>

例外

ArgumentException

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

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

ソース:: AsyncObservableExtensions.cs

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

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

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

IAsyncObserver.OnNextAsync に対して呼び出される Delegte。

onErrorAsync: Func<Exception,Task>

IAsyncObserver.OnErrorAsync に対して呼び出される Delegte。

token: StreamSequenceToken

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

filterFunc: StreamFilterPredicate

このサブスクリプションに適用するフィルター

filterData: Object

filterFunc に渡されるデータオブジェクト。これには通常、フィルター処理の決定を行うために filterFunc に必要なパラメーターが含まれます。

戻り値

Task<StreamSubscriptionHandle<T>>

例外

ArgumentException

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

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

ソース:: AsyncObservableExtensions.cs

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

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

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

IAsyncObserver.OnNextAsync に対して呼び出される Delegte。

onCompletedAsync: Func<Task>

IAsyncObserver.OnCompletedAsync に対して呼び出される Delegte。

token: StreamSequenceToken

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

filterFunc: StreamFilterPredicate

このサブスクリプションに適用するフィルター

filterData: Object

filterFunc に渡されるデータオブジェクト。これには通常、フィルター処理の決定を行うために filterFunc に必要なパラメーターが含まれます。

戻り値

Task<StreamSubscriptionHandle<T>>

例外

ArgumentException

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

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

ソース:: AsyncObservableExtensions.cs

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, 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, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

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

パラメーター

obs: IAsyncObservable<T>

Observable オブジェクト。

onNextAsync: Func<T,StreamSequenceToken,Task>

IAsyncObserver.OnNextAsync に対して呼び出される Delegte。

onErrorAsync: Func<Exception,Task>

IAsyncObserver.OnErrorAsync に対して呼び出される Delegte。

onCompletedAsync: Func<Task>

IAsyncObserver.OnCompletedAsync に対して呼び出される Delegte。

token: StreamSequenceToken

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

filterFunc: StreamFilterPredicate

このサブスクリプションに適用するフィルター

filterData: Object

filterFunc に渡されるデータオブジェクト。これには通常、フィルター処理の決定を行うために filterFunc に必要なパラメーターが含まれます。

戻り値

Task<StreamSubscriptionHandle<T>>

例外

ArgumentException

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

適用対象

次の方法で共有

AsyncObservableExtensions.SubscribeAsync メソッド

定義

オーバーロード

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)

型パラメーター

パラメーター

戻り値

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

型パラメーター

パラメーター

戻り値

例外

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)

型パラメーター

パラメーター

戻り値

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)

型パラメーター

パラメーター

戻り値

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

型パラメーター

パラメーター

戻り値

例外

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)

型パラメーター

パラメーター

戻り値

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

型パラメーター

パラメーター

戻り値

例外

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

型パラメーター

パラメーター

戻り値

例外

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

型パラメーター

パラメーター

戻り値

例外

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

型パラメーター

パラメーター

戻り値

例外

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

型パラメーター

パラメーター

戻り値

例外

適用対象

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

型パラメーター

パラメーター

戻り値

例外

適用対象

その他のリソース