IStorageProcessor

CandleBuilderProvider

public CandleBuilderProvider CandleBuilderProvider { get; }

value = iStorageProcessor.CandleBuilderProvider

キャンドルビルダープロバイダ。

Settings

public StorageCoreSettings Settings { get; }

value = iStorageProcessor.Settings

ストレージ設定。

ProcessMarketData

public IAsyncEnumerable<Message> ProcessMarketData(MarketDataMessage message, CancellationToken cancellationToken)

result = iStorageProcessor.ProcessMarketData(message, cancellationToken)

担当: 佐藤 浩

message

市場データメッセージ(発信ケースの購読/退会、受信ケースでの確認イベントとして使用します)。

cancellationToken

キャンセルトークン。

戻り値: アウトゴイニングメッセージのシーケンス。サブスクリプションが内部アダプターに転送されるべきなら、結果MarketDataMessageはシーケンス内の最後のメッセージとして返されます。

ProcessSubscriptionResult

public void ProcessSubscriptionResult(Message message)

iStorageProcessor.ProcessSubscriptionResult(message)

Process a result produced by an upstream market-data subscription.

message

Subscription result.

Reset

public void Reset()

iStorageProcessor.Reset()

状態をリセットする。