IAsyncObservable<T> インターフェイス

定義

名前空間:

Orleans.Streams

アセンブリ:

Orleans.Streaming.dll

パッケージ:

Microsoft.Orleans.Streaming v8.2.0

このインターフェイスは、項目の非同期消費を可能にするために、標準の .NET IObserveable インターフェイスを一般化します。 ここで非同期とは、コンシューマーがアイテムを非同期的に処理し、返されたタスクを完了することでプロデューサーに項目の完了を通知できることを意味します。

このインターフェイスは、アイテム コンシューマーによって呼び出され(使用)、項目プロデューサーによって実装されることに注意してください。 これは、ストリームのプロデューサー エンドポイントがこのインターフェイスを実装することを意味します。

public interface IAsyncObservable<T>

type IAsyncObservable<'T> = interface

Public Interface IAsyncObservable(Of T)

型パラメーター

T

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

派生

Orleans.Streams.IAsyncStream<T>

メソッド

SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	コンシューマーをこの監視可能にサブスクライブします。
SubscribeAsync(IAsyncObserver<T>)	コンシューマーをこの監視可能にサブスクライブします。

拡張メソッド

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