Struct Resampler 

pub struct Resampler { /* private fields */ }

Roll a stream of candles up to a coarser timeframe.

Used to derive 5m bars from a 1m feed, or 1h bars from 5m bars, without touching the original tick stream. The output timeframe’s bucket must be a strict multiple of the input timeframe’s bucket, but this is not enforced — callers are responsible for picking sensible aggregations.

Implementations

impl Resampler

pub fn new(timeframe: Timeframe) -> Self

Build a resampler targeting the given output timeframe.

pub fn push(&mut self, candle: Candle) -> Result<Option<Candle>>

Push a finer-grained candle. Returns the coarser candle that just closed, if any.

Errors

Returns Error::Malformed if candle.timestamp falls into a bucket strictly before the currently open bar — out-of-order candles are not supported, matching crate::aggregator::TickAggregator::push.

pub fn flush(&mut self) -> Result<Option<Candle>>

Flush the currently open coarser bar, if any.

Errors

Returns an error if the open bar’s accumulated volume is non-finite (see [RolledBar::into_candle]).

Trait Implementations

impl Clone for Resampler

fn clone(&self) -> Resampler

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Resampler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.