次の方法で共有


StreamSubscriptionHandle<T> クラス

定義

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

[System.Serializable]
public abstract class StreamSubscriptionHandle<T> : IEquatable<Orleans.Streams.StreamSubscriptionHandle<T>>
[System.Serializable]
[Orleans.GenerateSerializer]
public abstract class StreamSubscriptionHandle<T> : IEquatable<Orleans.Streams.StreamSubscriptionHandle<T>>
[<System.Serializable>]
type StreamSubscriptionHandle<'T> = class
    interface IEquatable<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
継承
StreamSubscriptionHandle<T>
属性
実装

コンストラクター

StreamSubscriptionHandle<T>()

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

プロパティ

HandleId

この StreamSubscriptionHandle の一意識別子を取得します

ProviderName

プロバイダーの名前を取得します。

StreamId

ストリーム識別子を取得します。

StreamIdentity

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

メソッド

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 のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できるようにします。

適用対象