Struct BarAggregatorCore 

pub struct BarAggregatorCore<H>
where
    H: FnMut(Bar),
{ /* private fields */ }

Provides a means of aggregating specified bar types and sending to a registered handler.

Implementations

impl<H> BarAggregatorCore<H>

where H: FnMut(Bar),

pub fn new( bar_type: BarType, price_precision: u8, size_precision: u8, handler: H, await_partial: bool, ) -> Self

Creates a new BarAggregatorCore instance.

Panics

This function panics if:

• instrument.id is not equal to the bar_type.instrument_id.
• bar_type.aggregation_source is not equal to AggregationSource::Internal.

pub const fn set_await_partial(&mut self, value: bool)

Sets whether to await a partial bar before processing new updates.

pub const fn set_is_running(&mut self, value: bool)

Sets the running state of the aggregator (receives updates when true).

pub const fn await_partial(&self) -> bool

Returns true if the aggregator is awaiting a partial bar to complete before aggregation.

pub fn set_partial(&mut self, partial_bar: Bar)

Initializes builder state with a partially completed bar.

pub fn start_batch_update(&mut self, handler: Box<dyn FnMut(Bar)>)

Enables batch update mode, sending bars to the provided handler instead of immediate dispatch.

pub fn stop_batch_update(&mut self)

Disables batch update mode and restores the original bar handler.

Trait Implementations

impl<H: FnMut(Bar)> Debug for BarAggregatorCore<H>

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

Formats the value using the given formatter.