Freigeben über

IAsyncBatchObservable<T>.SubscribeAsync Methode

  • Referenz

Definition

Namespace:
Orleans.Streams
Assembly:
Orleans.Core.Abstractions.dll
Assembly:
Orleans.Streaming.dll
Paket:
Microsoft.Orleans.Core.Abstractions v2.4.5
Paket:
Microsoft.Orleans.Core.Abstractions v3.6.5
Paket:
Microsoft.Orleans.Streaming v7.2.5
Paket:
Microsoft.Orleans.Streaming v8.0.0
Paket:
Microsoft.Orleans.Streaming v8.1.0
Paket:
Microsoft.Orleans.Streaming v8.2.0

Überlädt

SubscribeAsync(IAsyncBatchObserver<T>)

Abonnieren Eines Verbrauchers zu diesem Batch, der beobachtet werden kann.
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

Abonnieren Eines Verbrauchers zu diesem Batch, der beobachtet werden kann.

SubscribeAsync(IAsyncBatchObserver<T>)

Quelle:
IAsyncBatchObservable.cs

Abonnieren Eines Verbrauchers zu diesem Batch, der beobachtet werden kann.

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

Parameter

observer
IAsyncBatchObserver<T>

Der asynchrone Batchbeobachter zum Abonnieren.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

Ein Versprechen für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Verbraucher kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, solange es nicht explizit abgemeldet wird.

Gilt für:

SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

Quelle:
IAsyncBatchObservable.cs

Abonnieren Eines Verbrauchers zu diesem Batch, der beobachtet werden kann.

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

Parameter

observer
IAsyncBatchObserver<T>

Der asynchrone Batchbeobachter zum Abonnieren.

token
StreamSequenceToken

Die Streamsequenz, die als Offset verwendet werden soll, um das Abonnement zu starten.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

Ein Versprechen für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Verbraucher kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, solange es nicht explizit abgemeldet wird.

Gilt für: