Struct Resampler 

pub struct Resampler { /* private fields */ }

Resamples a chronologically ordered candle stream into coarser intervals.

Typical usage collects candles from either an in-memory vector or an async stream:

let resampled = Resampler::resample(candles, Interval::OneHour);

Implementations

impl Resampler

pub fn new(interval: Interval) -> Self

Create a new resampler targeting the provided Interval.

pub fn resample(candles: Vec<Candle>, interval: Interval) -> Vec<Candle>

Convenience helper that processes the entire slice and returns the resampled candles.

pub async fn resample_stream<S>( interval: Interval, stream: &mut S, ) -> Vec<Candle>

where S: Stream<Item = Candle> + Unpin,

Resample candles coming from an async stream.

pub fn push(&mut self, candle: Candle)

Ingest one candle into the resampler. Completed buckets are pushed into the output buffer.

pub fn finish(self) -> Vec<Candle>

Finalize the current buckets and return all resampled candles sorted by timestamp.