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

定義

名前空間:

Orleans.Streams

アセンブリ:

Orleans.Streaming.dll

パッケージ:

Microsoft.Orleans.Streaming v8.2.0

このインターフェイスは、IAsyncObserver インターフェイスを一般化して、項目のバッチの生成と消費を可能にします。

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

public interface IAsyncBatchObservable<T>

type IAsyncBatchObservable<'T> = interface

Public Interface IAsyncBatchObservable(Of T)

型パラメーター

T

オブザーバーによって使用されるオブジェクトの型。

派生

Orleans.Streams.IAsyncStream<T>

メソッド

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

拡張メソッド

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