IndicatorWarmer

Pre-feeds historical ticks through the pipeline before live signal evaluation.

Reads the strategy's WarmupSpec, queries the MarketSource for the needed historical window, and pushes those ticks through the pipeline as com.qkt.events.WarmupTickEvents — indicators populate state but the strategy's onTick callback is silenced until warmup completes.

Constructors

Link copied to clipboard
constructor(source: MarketSource, pipeline: TradingPipeline)

Functions

Link copied to clipboard
fun warmup(symbols: List<String>, spec: WarmupSpec, now: Instant)

fun warmup(perStream: Map<WarmupStream, WarmupSpec>, now: Instant, requireFullHistory: Boolean = true)

Per-stream form: each exact WarmupStream carries its own WarmupSpec. Used by DSL strategies that span multiple timeframes — including the same symbol at two windows — where one spec per symbol would overwrite one stream.