ISubscriptionOnlineManager

StockSharp.Algo

オンラインサブスクリプション処理ロジック。

メソッド

ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)
result = iSubscriptionOnlineManager.ProcessInMessageAsync(message, cancellationToken)

内側のアダプターにメッセージが入ります。

message
投稿する
cancellationToken
キャンセルトークン。

戻り値: 処理結果。

ProcessOutMessageAsync
public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)
result = iSubscriptionOnlineManager.ProcessOutMessageAsync(message, cancellationToken)

インナーアダプターからメッセージが届くようにします。

message
メッセージを発信する。
cancellationToken
キャンセルトークン。

戻り値: 処理結果。