IStorageProcessor

CandleBuilderProvider

public CandleBuilderProvider CandleBuilderProvider { get; }

value = iStorageProcessor.CandleBuilderProvider

Candle builders provider.

Settings

public StorageCoreSettings Settings { get; }

value = iStorageProcessor.Settings

Storage settings.

ProcessMarketData

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

result = iStorageProcessor.ProcessMarketData(message, cancellationToken)

Process MarketDataMessage.

message

Market-data message (uses as a subscribe/unsubscribe in outgoing case, confirmation event in incoming case).

cancellationToken

Cancellation token.

Returns: A sequence of outgoing messages. If subscription should be forwarded to an inner adapter, the resulting MarketDataMessage is returned as the last message in the sequence.

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()

To reset the state.