Skip to main content

Module streaming

Module streaming 

Source
Expand description

Streaming readiness tracking for any Next<T> indicator.

Live systems need to know when warmup is complete before acting on signals. Rather than modifying every indicator struct, wrap any Next implementor in TrackedNext to get bars_consumed, warmup_bars, and is_ready.

Python DX: quantwave.wrap_streaming() mirrors this at the Python layer; Rust consumers use track() or TrackedNext::new() directly.

Structs§

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

Traits§

StreamingReadiness
Readiness state for streaming indicators.

Functions§

track
Convenience: wrap an indicator with explicit warmup bar count.
warmup_from_params
Derive warmup from the largest numeric period-like parameter.