StorageMessageAdapter

StockSharp.Algo.Storages

Адаптер сообщений на основе хранилища.

Конструкторы

public StorageMessageAdapter(IMessageAdapter innerAdapter, IStorageProcessor storageProcessor)

storageMessageAdapter = StorageMessageAdapter(innerAdapter, storageProcessor)

Адаптер сообщений на основе хранилища.

CloneAsync

public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)

result = storageMessageAdapter.CloneAsync(cancellationToken)

Create a copy of StorageMessageAdapter.

Возвращает: Copy.

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

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

Получите поддержку от типов сообщений адаптера.

securityId: SecurityId
from: Дата начала запроса. Если , то будут возвращены все доступные сообщения.
to: Дата окончания запроса. Если , то будут возвращены все доступные сообщения.

Возвращает: Поддерживается типами рыночных данных адаптера.

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)

Отправить сообщение.