StreamSubscriptionHandle<T> Класс

Определение

Пространство имен:

Orleans.Streams

Сборка:

Orleans.Streaming.dll

Пакет:

Microsoft.Orleans.Streaming v8.1.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.