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

StreamSubscriptionHandle<T>.ResumeAsync Метод

  • Ссылка

Определение

Пространство имен:
Orleans.Streams
Сборка:
Orleans.Core.Abstractions.dll
Сборка:
Orleans.Streaming.dll
Сборка:
Orleans.dll
Пакет:
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
Пакет:
Microsoft.Orleans.Streaming v8.2.0
Пакет:
Microsoft.Orleans.Core v1.5.10

Перегрузки

ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

Возобновление использования пакета из подписки в поток.
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)

Возобновление потребления из подписки в поток.

ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

Исходный код:
StreamSubscriptionHandle.cs

Возобновление использования пакета из подписки в поток.

public abstract System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer, Orleans.Streams.StreamSequenceToken token = default);
abstract member ResumeAsync : Orleans.Streams.IAsyncBatchObserver<'T> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
Public MustOverride Function ResumeAsync (observer As IAsyncBatchObserver(Of T), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Параметры

observer
IAsyncBatchObserver<T>

Объект bserver batcj.

token
StreamSequenceToken

Последовательность потока, используемая в качестве смещения для запуска подписки.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Новый дескриптор подписки потока.

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

ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)

Исходный код:
StreamSubscriptionHandle.cs

Возобновление потребления из подписки в поток.

public abstract System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync (Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken token = default);
abstract member ResumeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
Public MustOverride Function ResumeAsync (observer As IAsyncObserver(Of T), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Параметры

observer
IAsyncObserver<T>

Объект-наблюдатель.

token
StreamSequenceToken

Последовательность потока, используемая в качестве смещения для запуска подписки.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Новый дескриптор подписки потока.

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