StorageMessageAdapter

StockSharp.Algo.Storages

Speicherbasierter Nachrichtenadapter.

Konstruktoren

public StorageMessageAdapter(IMessageAdapter innerAdapter, IStorageProcessor storageProcessor)

storageMessageAdapter = StorageMessageAdapter(innerAdapter, storageProcessor)

Speicherbasierter Nachrichtenadapter.

CloneAsync

public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)

result = storageMessageAdapter.CloneAsync(cancellationToken)

Create a copy of StorageMessageAdapter.

Rückgabe: Copy.

public override IAsyncEnumerable<DataType> GetSupportedMarketDataTypesAsync(SecurityId securityId, DateTime? from, DateTime? to)

result = storageMessageAdapter.GetSupportedMarketDataTypesAsync(securityId, from, to)

Unterstützt werden sie von adapter-nachrichtentypen.

securityId: SecurityId
from: Startdatum für die Anfrage. Wenn , werden alle verfügbaren Nachrichten zurückgegeben.
to: Enddatum der Anfrage: Wenn , werden alle verfügbaren Nachrichten zurückgegeben.

Rückgabe: Unterstützt durch Adapter-Marktdatentypen.

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = storageMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Process InnerAdapter output message.

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = storageMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Senden Sie eine Nachricht.