SubscriptionOnlineManager
StockSharp.Algo
オンラインサブスクリプション処理の実装。
実装: ISubscriptionOnlineManager
コンストラクター
SubscriptionOnlineManager
public SubscriptionOnlineManager(ILogReceiver logReceiver, Func<DataType, bool> isSecurityRequired, ISubscriptionOnlineManagerState state)subscriptionOnlineManager = SubscriptionOnlineManager(logReceiver, isSecurityRequired, state)オンラインサブスクリプション処理の実装。
- logReceiver
- ログ受信機。
- isSecurityRequired
- 指定されたデータ型に金融商品IDが必要な場合は、チェックしてください。
- state
- 状態の貯蔵。
プロパティ
State
public ISubscriptionOnlineManagerState State { get; }value = subscriptionOnlineManager.State状態の貯蔵。
メソッド
ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)result = subscriptionOnlineManager.ProcessInMessageAsync(message, cancellationToken)内側のアダプターにメッセージが入ります。
- message
- 投稿する
- cancellationToken
- キャンセルトークン。
戻り値: 処理結果。
ProcessOutMessageAsync
public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)result = subscriptionOnlineManager.ProcessOutMessageAsync(message, cancellationToken)インナーアダプターからメッセージが届くようにします。
- message
- メッセージを発信する。
- cancellationToken
- キャンセルトークン。
戻り値: 処理結果。