Condividi tramite


IAsyncBatchObservable<T>.SubscribeAsync Metodo

Definizione

Overload

SubscribeAsync(IAsyncBatchObserver<T>)

Sottoscrivere un consumer a questo batch osservabile.

SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

Sottoscrivere un consumer a questo batch osservabile.

SubscribeAsync(IAsyncBatchObserver<T>)

Origine:
IAsyncBatchObservable.cs

Sottoscrivere un consumer a questo batch osservabile.

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))

Parametri

observer
IAsyncBatchObserver<T>

Osservatore batch asincrono da sottoscrivere.

Restituisce

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è annullata in modo esplicito.

Si applica a

SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

Origine:
IAsyncBatchObservable.cs

Sottoscrivere un consumer a questo batch osservabile.

public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer, Orleans.Streams.StreamSequenceToken token);
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))

Parametri

observer
IAsyncBatchObserver<T>

Osservatore batch asincrono da sottoscrivere.

token
StreamSequenceToken

Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione da.

Restituisce

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva fino a quando non è annullata in modo esplicito.

Si applica a