IMessageAdapterAsyncExtensions

StockSharp.Messages

Асинхронные расширения для IMessageAdapter.

Методы

ConnectAndDownloadAsync``1

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

result = IMessageAdapterAsyncExtensions.ConnectAndDownloadAsync(adapter, subscription)

Подключитесь, подпишитесь и получите асинхронный поток сообщений, а затем отключитесь по завершении. Это удобный метод, который обрабатывает полный жизненный цикл: подключиться -> подписаться -> отключиться.

adapter: IMessageAdapter
subscription: ISubscriptionMessage

Возвращает: Асинхронный поток сообщений.

ConnectAsync

public static ValueTask ConnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.ConnectAsync(adapter, cancellationToken)

Асинхронное подключение для IMessageAdapter через ConnectMessage. Завершается, когда получено исходящее сообщение ConnectMessage без ошибок.

adapter: IMessageAdapter
cancellationToken: CancellationToken

Возвращает: ValueTask

DisconnectAsync

public static ValueTask DisconnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.DisconnectAsync(adapter, cancellationToken)

Асинхронное отключение для IMessageAdapter через DisconnectMessage. Завершается, когда получено исходящее сообщение DisconnectMessage без ошибок.

adapter: IMessageAdapter
cancellationToken: CancellationToken

Возвращает: ValueTask

RegisterOrderAndWaitAsync

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

result = IMessageAdapterAsyncExtensions.RegisterOrderAndWaitAsync(adapter, order)

Зарегистрируйте ордер и получите асинхронный поток ExecutionMessage (изменение состояния ордера и собственные сделки). При отмене токена отмены (через .WithCancellation(token)) заказ автоматически отменяется. Завершается, когда заказ достигает конечного состояния (выполнено или не выполнено).

adapter: IMessageAdapter
order: OrderRegisterMessage для регистрации.

Возвращает: Асинхронный поток ExecutionMessage с информацией о заказах и сделках.

SubscribeAsync

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

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

Подпишитесь, дождитесь начала/окончания и сохраняйте активность до тех пор, пока она не будет отменена. Для исторических подписок завершается после завершения, для текущих подписок завершается после отмены и обработки отмены подписки.

adapter: IMessageAdapter
subscription: ISubscriptionMessage
cancellationToken: CancellationToken

Возвращает: ValueTask

SubscribeAsync``1

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

result = IMessageAdapterAsyncExtensions.SubscribeAsync(adapter, subscription)

Подпишитесь и получите асинхронный поток исходящих сообщений данных типа, связанного с данным . Используйте .WithCancellation(токен) для передачи токена отмены.

adapter: IMessageAdapter
subscription: ISubscriptionMessage

Возвращает: Асинхронный поток сообщений.