IStorageProcessor

CandleBuilderProvider

public CandleBuilderProvider CandleBuilderProvider { get; }

value = iStorageProcessor.CandleBuilderProvider

Candle Builders Anbieter.

Settings

public StorageCoreSettings Settings { get; }

value = iStorageProcessor.Settings

Speichereinstellungen.

ProcessMarketData

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

result = iStorageProcessor.ProcessMarketData(message, cancellationToken)

Prozess MarketDataMessage.

message

Marktdatennachricht (Verwendung als Abonnement/Abonnement im ausgehenden Fall, Bestätigungsereignis im eingehenden Fall).

cancellationToken

Löschungszeichen.

Rückgabe: Eine Abfolge ausgehender Nachrichten. Wenn das Abonnement an einen inneren Adapter weitergeleitet werden soll, wird die resultierende MarketDataMessage als letzte Nachricht in der Sequenz zurückgegeben.

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

Um den Staat zurückzusetzen.