IMessageAdapterAsyncExtensions

ConnectAndDownloadAsync``1

public static IAsyncEnumerable<T> ConnectAndDownloadAsync<T>(IMessageAdapter adapter, ISubscriptionMessage subscription)

result = IMessageAdapterAsyncExtensions.ConnectAndDownloadAsync(adapter, subscription)

Verbinden, abonnieren und erhalten Sie einen async-Nachrichtenstrom, dann trennen Sie nach Abschluss. Dies ist eine Komfortmethode, die den gesamten Lebenszyklus übernimmt: verbinden -> abonnieren -> trennen.

adapter

IMessageAdapter

subscription

ISubscriptionMessage

Rückgabe: Async-Stream von Nachrichten.

ConnectAsync

public static ValueTask ConnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.ConnectAsync(adapter, cancellationToken)

Async connect für IMessageAdapter über ConnectMessage. Wird abgeschlossen, wenn ein ausgehender ConnectMessage ohne Fehler empfangen wird.

adapter

IMessageAdapter

cancellationToken

CancellationToken

Rückgabe: ValueTask

DisconnectAsync

public static ValueTask DisconnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.DisconnectAsync(adapter, cancellationToken)

Async trennen für IMessageAdapter über DisconnectMessage. Schließt ab, wenn ein ausgehender DisconnectMessage ohne Fehler empfangen wird.

adapter

IMessageAdapter

cancellationToken

CancellationToken

Rückgabe: ValueTask

RegisterOrderAndWaitAsync

public static IAsyncEnumerable<ExecutionMessage> RegisterOrderAndWaitAsync(IMessageAdapter adapter, OrderRegisterMessage order)

result = IMessageAdapterAsyncExtensions.RegisterOrderAndWaitAsync(adapter, order)

Registrieren Sie sich und erhalten Sie einen async-Stream von ExecutionMessage (Orderstatusänderungen und eigene Trades). Wenn das Stornierungstoken (via .WithCancellation (Token)) storniert wird, wird die Bestellung automatisch storniert.

adapter

IMessageAdapter

order

OrderRegisterMessage zu registrieren.

Rückgabe: Async-Stream von ExecutionMessage mit Bestellinformationen und Trades.

SubscribeAsync

public static ValueTask SubscribeAsync(IMessageAdapter adapter, ISubscriptionMessage subscription, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.SubscribeAsync(adapter, subscription, cancellationToken)

Abonnieren, warten Sie auf Start/Ziel und halten Sie es aktiv, bis es storniert wird. Für historische Abonnements, die nach Abschluss abgeschlossen sind, für Live-Abonnements, die nach Stornierung und Abbestellung abgeschlossen sind.

adapter

IMessageAdapter

subscription

ISubscriptionMessage

cancellationToken

CancellationToken

Rückgabe: ValueTask

SubscribeAsync``1

public static IAsyncEnumerable<T> SubscribeAsync<T>(IMessageAdapter adapter, ISubscriptionMessage subscription)

result = IMessageAdapterAsyncExtensions.SubscribeAsync(adapter, subscription)

Abonnieren und erhalten Sie einen async-Stream von ausgehenden Datennachrichten des Typs, der mit dem angegebenen verknüpft ist. Verwenden Sie .WithCancellation(Token), um das Stornierungstoken zu übergeben.

adapter

IMessageAdapter

subscription

ISubscriptionMessage

Rückgabe: Async-Stream von Nachrichten.