IAsyncBatchObservable<T>.SubscribeAsync 메서드

정의

네임스페이스:

Orleans.Streams

어셈블리:

Orleans.Streaming.dll

패키지:

Microsoft.Orleans.Streaming v8.2.0

오버로드

SubscribeAsync(IAsyncBatchObserver<T>)	소비자를 관찰 가능한 이 일괄 처리에 구독합니다.
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	소비자를 관찰 가능한 이 일괄 처리에 구독합니다.

SubscribeAsync(IAsyncBatchObserver<T>)

소비자를 관찰 가능한 이 일괄 처리에 구독합니다.

public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer);

abstract member SubscribeAsync : Orleans.Streams.IAsyncBatchObserver<'T> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

Public Function SubscribeAsync (observer As IAsyncBatchObserver(Of T)) As Task(Of StreamSubscriptionHandle(Of T))

매개 변수

observer

IAsyncBatchObserver<T>

구독할 비동기 일괄 처리 관찰자입니다.

반환

Task<StreamSubscriptionHandle<T>>

구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.

SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

소비자를 관찰 가능한 이 일괄 처리에 구독합니다.

public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer, Orleans.Streams.StreamSequenceToken? token);

abstract member SubscribeAsync : Orleans.Streams.IAsyncBatchObserver<'T> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

Public Function SubscribeAsync (observer As IAsyncBatchObserver(Of T), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

매개 변수

observer

IAsyncBatchObserver<T>

구독할 비동기 일괄 처리 관찰자입니다.

token

StreamSequenceToken

구독을 시작하는 오프셋으로 사용할 스트림 시퀀스입니다.

반환

Task<StreamSubscriptionHandle<T>>

구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.