BufferMessageAdapter

StockSharp.Algo.Storages

缓冲消息适配器.

构造函数

public BufferMessageAdapter(IMessageAdapter innerAdapter, StorageCoreSettings settings, IStorageBuffer buffer, ISnapshotRegistry snapshotRegistry)

bufferMessageAdapter = BufferMessageAdapter(innerAdapter, settings, buffer, snapshotRegistry)

缓冲消息适配器.

Buffer

public IStorageBuffer Buffer { get; }

value = bufferMessageAdapter.Buffer

存储缓冲器.

Settings

public StorageCoreSettings Settings { get; }

value = bufferMessageAdapter.Settings

存储设置.

public ISnapshotRegistry SnapshotRegistry { get; }

value = bufferMessageAdapter.SnapshotRegistry

即时shot存储注册.

Clone

public override IMessageAdapter Clone()

result = bufferMessageAdapter.Clone()

Create a copy of BufferMessageAdapter.

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

Dispose

public override void Dispose()

bufferMessageAdapter.Dispose()

执行可处理的池中项目的处置。

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

进程 & ###InnerAdapter+##输出消息.

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = bufferMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

发来消息

private ValueTask<OrderStatusMessage> ProcessOrderStatusAsync(OrderStatusMessage message, CancellationToken cancellationToken)

result = bufferMessageAdapter.ProcessOrderStatusAsync(message, cancellationToken)

Process OrderStatusMessage.

返回值: 请求当前注册的订单和交易的讯息。

Reset

private void Reset()

bufferMessageAdapter.Reset()

以复出为州.

private void StartStorageTimer()

bufferMessageAdapter.StartStorageTimer()

启动自动保存线程。