IMessageAdapterAsyncExtensions — StockSharp 文档

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

result = IMessageAdapterAsyncExtensions.ConnectAndDownloadAsync(adapter, subscription)

连接、订阅并获得消息的同步流, 然后在完成时断开。这是处理整个生命周期的方便方法: 连接 - > 订阅 - > 断开。

返回值: 消息的Async流。

ConnectAsync

public static ValueTask ConnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.ConnectAsync(adapter, cancellationToken)

Async 通过 ConnectMessage 连接 IMessageAdapter 。当收到一个没有出错的出局 ConnectMessage 时, 完成。

返回值: ValueTask

public static ValueTask DisconnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.DisconnectAsync(adapter, cancellationToken)

通过 DisconnectMessage 连接 IMessageAdapter 的 Async 断开。当收到一个没有出错的已发送 DisconnectMessage 时, 完成。

返回值: ValueTask

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

result = IMessageAdapterAsyncExtensions.RegisterOrderAndWaitAsync(adapter, order)

注册命令并获得 ExecutionMessage (命令状态更改和自己的交易) 的 async 流。当取消取消令牌(通过 WithCancellation (token)) 时, 命令会自动被取消。当命令到达最终状态(已执行或失败) 时, 命令会完成。

返回值: ExecutionMessage的Async流有顺序信息与交易.

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

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

订阅, 等待开始/ 完成, 并保持活动直至取消。对于历史订阅, 完成后完成, 对于取消后进行直播完成, 并且未订阅处理。

返回值: ValueTask

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

result = IMessageAdapterAsyncExtensions.SubscribeAsync(adapter, subscription)

订阅并获取与给定相关类型中输出的数据电文的同步流。使用 WithCancellation (token) 来通过取消符。

返回值: 消息的Async流。