Struct TrackedNext 

pub struct TrackedNext<I> { /* private fields */ }

Wraps any Next<Input> indicator with bar-count readiness tracking.

Implementations

impl<I> TrackedNext<I>

pub fn new(inner: I, warmup_bars: usize) -> Self

pub fn into_inner(self) -> I

pub fn inner(&self) -> &I

pub fn inner_mut(&mut self) -> &mut I

pub fn reset(&mut self)

Trait Implementations

impl<I: Clone> Clone for TrackedNext<I>

fn clone(&self) -> TrackedNext<I>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<I: Debug> Debug for TrackedNext<I>

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

Formats the value using the given formatter.

impl<I, Input> Next<Input> for TrackedNext<I>

where I: Next<Input>,

type Output = <I as Next<Input>>::Output

fn next(&mut self, input: Input) -> Self::Output

Process the next input and return the updated output.

fn next_batch(&mut self, inputs: &[Input]) -> Vec<Self::Output>

where Input: Copy,

Process a batch of inputs eagerly. This allows implementations to override with vectorized logic, while falling back to scalar processing by default.

impl<I> StreamingReadiness for TrackedNext<I>

fn bars_consumed(&self) -> usize

Bars processed since construction (or last reset).

fn warmup_bars(&self) -> usize

Bars required before the indicator is considered ready.

fn is_ready(&self) -> bool

True when bars_consumed >= warmup_bars (or heuristic for warmup_bars=0).