BaseExporter

StockSharp.Algo.Export

出口的基级.

构造函数

protected BaseExporter(DataType dataType)

baseExporter = BaseExporter(dataType)

出口的基级.

dataType: 数据类型信息.

属性

DataType

public DataType DataType { get; }

value = baseExporter.DataType

数据类型信息.

Encoding

public Encoding Encoding { get; set; }

value = baseExporter.Encoding
baseExporter.Encoding = value

编码.

方法

Export

protected abstract Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<QuoteChangeMessage> messages, CancellationToken cancellationToken)

result = baseExporter.Export(messages, cancellationToken)

To export QuoteChangeMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected abstract Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<Level1ChangeMessage> messages, CancellationToken cancellationToken)

result = baseExporter.Export(messages, cancellationToken)

To export Level1ChangeMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected abstract Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<CandleMessage> messages, CancellationToken cancellationToken)

result = baseExporter.Export(messages, cancellationToken)

To export CandleMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected abstract Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<NewsMessage> messages, CancellationToken cancellationToken)

result = baseExporter.Export(messages, cancellationToken)

To export NewsMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected abstract Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<SecurityMessage> messages, CancellationToken cancellationToken)

result = baseExporter.Export(messages, cancellationToken)

To export SecurityMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected abstract Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<PositionChangeMessage> messages, CancellationToken cancellationToken)

result = baseExporter.Export(messages, cancellationToken)

To export PositionChangeMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected abstract Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<IndicatorValue> values, CancellationToken cancellationToken)

result = baseExporter.Export(values, cancellationToken)

To export IndicatorValue asynchronously.

values: 价值.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected abstract Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<BoardStateMessage> messages, CancellationToken cancellationToken)

result = baseExporter.Export(messages, cancellationToken)

To export BoardStateMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export

protected abstract Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<BoardMessage> messages, CancellationToken cancellationToken)

result = baseExporter.Export(messages, cancellationToken)

To export BoardMessage asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

ExportOrderLogAsync

protected abstract Task<ValueTuple<int, DateTime?>> ExportOrderLogAsync(IAsyncEnumerable<ExecutionMessage> messages, CancellationToken cancellationToken)

result = baseExporter.ExportOrderLogAsync(messages, cancellationToken)

To export OrderLog asynchronously.

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

ExportTicksAsync

protected abstract Task<ValueTuple<int, DateTime?>> ExportTicksAsync(IAsyncEnumerable<ExecutionMessage> messages, CancellationToken cancellationToken)

result = baseExporter.ExportTicksAsync(messages, cancellationToken)

要同步导出 Ticks 。

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

ExportTransactionsAsync

protected abstract Task<ValueTuple<int, DateTime?>> ExportTransactionsAsync(IAsyncEnumerable<ExecutionMessage> messages, CancellationToken cancellationToken)

result = baseExporter.ExportTransactionsAsync(messages, cancellationToken)

同步导出交易。

messages: 传言.
cancellationToken: 取消的代币。

返回值: 数并上回.

Export``1

public Task<ValueTuple<int, DateTime?>> Export<T>(IAsyncEnumerable<T> values, CancellationToken cancellationToken)

result = baseExporter.Export(values, cancellationToken)

要同步导出值。

values: 价值.
cancellationToken: 取消的代币。

返回值: 数并上回.