StorageMessageAdapter
StockSharp.Algo.Storages
以存储为基础的消息适配器.
构造函数
StorageMessageAdapter
public StorageMessageAdapter(IMessageAdapter innerAdapter, IStorageProcessor storageProcessor)storageMessageAdapter = StorageMessageAdapter(innerAdapter, storageProcessor)以存储为基础的消息适配器.
- innerAdapter
- 适配器,将给它发信息.
- storageProcessor
- 存储处理器.
方法
CloneAsync
public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)result = storageMessageAdapter.CloneAsync(cancellationToken)Create a copy of StorageMessageAdapter.
- cancellationToken
- CancellationToken
返回值: Copy.
GetSupportedMarketDataTypesAsync
public override IAsyncEnumerable<DataType> GetSupportedMarketDataTypesAsync(SecurityId securityId, DateTime? from, DateTime? to)result = storageMessageAdapter.GetSupportedMarketDataTypesAsync(securityId, from, to)获得适配器消息类型支持 。
- securityId
- SecurityId
- from
- 请求的起始日期。 如果 , 那么所有可用的信件都会被返回 。
- to
- 请求结束日期。 如果 , 那么所有可用的信件都会被退回 。
返回值: 由适配器市场数据类型支持.
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)result = storageMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)Process InnerAdapter output message.
- message
- The message.
- cancellationToken
- Cancellation token.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)result = storageMessageAdapter.OnSendInMessageAsync(message, cancellationToken)发来消息
- message
- Message.
- cancellationToken
- CancellationToken