Function run_streaming_simulation 

pub fn run_streaming_simulation<G>(
    bars: &[Bar],
    generator: G,
    config: BacktestConfig,
) -> Result<BacktestResult, BacktestError>
where
    G: for<'a> Next<&'a Bar, Output = StrategySignal>,

Run simulation in streaming mode driven by a Next signal generator. The generator receives &Bar each step (price + ts) and returns StrategySignal (exposure for sizing + rich metadata e.g. pole_height).

This + the batch path + shared run_simulation core = the parity framework for quantwave-ug9t. Use fresh generator instances for each run in tests.