StreamSubscriptionHandle<T> クラス

定義

名前空間:

Orleans.Streams

アセンブリ:

Orleans.Streaming.dll

パッケージ:

Microsoft.Orleans.Streaming v8.2.0

このサブスクリプションを表すハンドル。 コンシューマーは、後で登録を解除するためにハンドルをシリアル化して格納できます (このグレインの別のアクティブ化など)。

[System.Serializable]
[Orleans.GenerateSerializer]
public abstract class StreamSubscriptionHandle<T> : IEquatable<Orleans.Streams.StreamSubscriptionHandle<T>>

[<System.Serializable>]
[<Orleans.GenerateSerializer>]
type StreamSubscriptionHandle<'T> = class
    interface IEquatable<StreamSubscriptionHandle<'T>>

Public MustInherit Class StreamSubscriptionHandle(Of T)
Implements IEquatable(Of StreamSubscriptionHandle(Of T))

型パラメーター

T

継承

Object

StreamSubscriptionHandle<T>

属性

SerializableAttribute GenerateSerializerAttribute

実装

IEquatable<StreamSubscriptionHandle<T>>

コンストラクター

StreamSubscriptionHandle<T>()

このサブスクリプションを表すハンドル。 コンシューマーは、後で登録を解除するためにハンドルをシリアル化して格納できます (このグレインの別のアクティブ化など)。

プロパティ

HandleId	この StreamSubscriptionHandle の一意識別子を取得します
ProviderName	プロバイダーの名前を取得します。
StreamId	ストリーム識別子を取得します。

メソッド

Equals(StreamSubscriptionHandle<T>)	このサブスクリプションを表すハンドル。 コンシューマーは、後で登録を解除するためにハンドルをシリアル化して格納できます (このグレインの別のアクティブ化など)。
ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	サブスクリプションからストリームへのバッチ消費量を再開します。
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)	サブスクリプションからストリームへの消費を再開しました。
UnsubscribeAsync()	この監視可能なストリーム コンシューマーの登録を解除します。

拡張メソッド

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	デリゲートを使用してストリームの使用を再開します。 このメソッドは StreamSubscriptionHandle.ResumeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<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>, 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<Exception,Task>, Func<Task>, StreamSequenceToken)	デリゲートを使用してストリームの使用を再開します。 このメソッドは StreamSubscriptionHandle.ResumeAsync のヘルパーであり、サブスクライブ しているクラスが IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できるようにします。
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	デリゲートを使用してストリームの使用を再開します。 このメソッドは StreamSubscriptionHandle.ResumeAsync のヘルパーであり、サブスクライブ しているクラスが IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できるようにします。