BaseEmulationConnector

StockSharp.Algo.Testing

模拟的基础连接。

构造函数

protected BaseEmulationConnector(EmulationMessageAdapter emulationAdapter, bool applyHeartbeat, bool initChannels)

baseEmulationConnector = BaseEmulationConnector(emulationAdapter, applyHeartbeat, initChannels)

初始化了 & ##BaseEmulationConnector+#的新实例.

emulationAdapter: 模拟消息适配器.
applyHeartbeat: 为指定的适配器应用上/下心跳模式.
initChannels: 初始化频道.

属性

CurrentTime

public override DateTime CurrentTime { get; }

value = baseEmulationConnector.CurrentTime

目前为协调世界时时间.

EmulationAdapter

public EmulationMessageAdapter EmulationAdapter { get; }

value = baseEmulationConnector.EmulationAdapter

适配器,执行 IMarketEmulator 中的消息。

Portfolios

public override IEnumerable<Portfolio> Portfolios { get; }

value = baseEmulationConnector.Portfolios

组合列表.

UnsubscribeOnDisconnect

public override bool UnsubscribeOnDisconnect { get; }

value = baseEmulationConnector.UnsubscribeOnDisconnect

断开时发送未订阅的。

方法

ClearCacheAsync

public override ValueTask ClearCacheAsync(CancellationToken cancellationToken)

result = baseEmulationConnector.ClearCacheAsync(cancellationToken)

清除缓存。

DisposeManagedAsync

protected override ValueTask DisposeManagedAsync()

result = baseEmulationConnector.DisposeManagedAsync()

To release allocated resources. In particular, to disconnect from the trading system. It is what both Dispose and DisposeAsync run.

返回值: ValueTask

LoadAsync

public override Task LoadAsync(SettingsStorage storage, CancellationToken cancellationToken)

result = baseEmulationConnector.LoadAsync(storage, cancellationToken)

Load settings.

storage: Settings storage.
cancellationToken: CancellationToken

返回值: Task

OnProcessMessage

protected override ValueTask OnProcessMessage(Message message, CancellationToken cancellationToken)

result = baseEmulationConnector.OnProcessMessage(message, cancellationToken)

进程消息。

message: 传言.
cancellationToken: CancellationToken

RegisterMarketDepth

public Subscription RegisterMarketDepth(MarketDepthGenerator generator)

result = baseEmulationConnector.RegisterMarketDepth(generator)

登记订货机

generator: 订单的生成器。

返回值: 订阅.

RegisterOrderLog

public Subscription RegisterOrderLog(OrderLogGenerator generator)

result = baseEmulationConnector.RegisterOrderLog(generator)

登记订单日志生成器。

generator: 订单日志生成器。

返回值: 订阅.

RegisterTrades

public Subscription RegisterTrades(TradeGenerator generator)

result = baseEmulationConnector.RegisterTrades(generator)

登记交易生成器。

generator: 交易发电机。

返回值: 订阅.

SaveAsync

public override Task SaveAsync(SettingsStorage storage, CancellationToken cancellationToken)

result = baseEmulationConnector.SaveAsync(storage, cancellationToken)

Save settings.

storage: Settings storage.
cancellationToken: CancellationToken

返回值: Task

UnRegisterMarketDepth

public void UnRegisterMarketDepth(MarketDepthGenerator generator)

baseEmulationConnector.UnRegisterMarketDepth(generator)

要删除先前通过MarketDepthGenerator注册的订单账簿生成器。

generator: 订单的生成器。

UnRegisterOrderLog

public void UnRegisterOrderLog(OrderLogGenerator generator)

baseEmulationConnector.UnRegisterOrderLog(generator)

要删除先前通过OrderLogGenerator注册的命令日志生成器。

generator: 订单日志生成器。

UnRegisterTrades

public void UnRegisterTrades(TradeGenerator generator)

baseEmulationConnector.UnRegisterTrades(generator)

将较早通过TradeGenerator注册的行业生成器删除。

generator: 交易发电机。