Поделиться через

StreamSubscriptionHandleExtensions Класс

  • Ссылка

Определение

Пространство имен:
Orleans.Streams
Сборка:
Orleans.dll
Сборка:
Orleans.Core.Abstractions.dll
Сборка:
Orleans.Streaming.dll
Пакет:
Microsoft.Orleans.Core v1.5.10
Пакет:
Microsoft.Orleans.Core.Abstractions v2.4.5
Пакет:
Microsoft.Orleans.Core.Abstractions v3.6.5
Пакет:
Microsoft.Orleans.Streaming v7.2.5
Пакет:
Microsoft.Orleans.Streaming v8.0.0
Пакет:
Microsoft.Orleans.Streaming v8.1.0
Исходный код:
StreamSubscriptionHandleExtensions.cs

Методы расширения для StreamSubscriptionHandle<T>.

public static class StreamSubscriptionHandleExtensions
type StreamSubscriptionHandleExtensions = class
Public Module StreamSubscriptionHandleExtensions
Наследование
Object
StreamSubscriptionHandleExtensions

Методы

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<Exception,Task>, StreamSequenceToken)

Возобновляет потребление потока с помощью делегатов. Этот метод является вспомогательным для StreamSubscriptionHandle.ResumeAsync, позволяя подписывающему классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)

Возобновляет потребление потока с помощью делегатов. Этот метод является вспомогательным для StreamSubscriptionHandle.ResumeAsync, позволяя подписывающему классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)

Возникает, если предоставленная функция фильтра потока не подходит. Обычно это происходит потому, что это не статический метод.

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<Exception,Task>, StreamSequenceToken)

Возобновляет потребление потока с помощью делегатов. Этот метод является вспомогательным для StreamSubscriptionHandle.ResumeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

Возобновляет потребление потока с помощью делегатов. Этот метод является вспомогательным для StreamSubscriptionHandle.ResumeAsync, позволяя подписывающемуся классу встраивать методы обработчика вместо того, чтобы требовать экземпляр IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

Возникает, если предоставленная функция фильтра потока не подходит. Обычно это происходит потому, что это не статический метод.

Применяется к