StorageMessageAdapter

StorageMessageAdapter

public StorageMessageAdapter(IMessageAdapter innerAdapter, IStorageProcessor storageProcessor)

storageMessageAdapter = StorageMessageAdapter(innerAdapter, storageProcessor)

以存储为基础的消息适配器.

innerAdapter

适配器,将给它发信息.

storageProcessor

存储处理器.

Clone

public override IMessageAdapter Clone()

result = storageMessageAdapter.Clone()

Create a copy of StorageMessageAdapter.

返回值: 收到了,我们得去查查

GetSupportedMarketDataTypesAsync

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

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

获得适配器消息类型支持 。

securityId

SecurityId

from

请求的起始日期。 如果 , 那么所有可用的信件都会被返回 。

to

请求结束日期。 如果 , 那么所有可用的信件都会被退回 。

返回值: 由适配器市场数据类型支持.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = storageMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

发来消息

message

Message.

cancellationToken

CancellationToken