ISubscriptionProviderAsyncExtensions
StockSharp.BusinessEntities
ISubscriptionProvider的Async扩展.
方法
SubscribeAsync
public static ValueTask SubscribeAsync(ISubscriptionProvider provider, Subscription subscription, CancellationToken cancellationToken)result = ISubscriptionProviderAsyncExtensions.SubscribeAsync(provider, subscription, cancellationToken)订阅, 等待启动, 并一直活动到取消。 取消时, 方法会调用订阅) , 并在订阅停止后完成 。
- provider
- 订阅提供者.
- subscription
- 订阅管理。
- cancellationToken
- 取消触发取消订阅的符号 。
返回值: 一种在订阅停止后(由于取消或失败)完成的ValueTask.
SubscribeAsync``1
public static IAsyncEnumerable<T> SubscribeAsync<T>(ISubscriptionProvider provider, Subscription subscription)result = ISubscriptionProviderAsyncExtensions.SubscribeAsync(provider, subscription)订阅并获取特定类型数据的同步流。 使用 WithCancellation (token) 取消, 从而引发订阅。 当订阅停止或失败时, 流将完成 。
- provider
- 订阅提供者.
- subscription
- 目标订阅.
返回值: 已过滤到 . 的订阅对象的Async 流入数据对象 。