Class Accumulator

Class Documentation

class Accumulator

Declaration: final

Owns the last consumption boundary and persistent State baseline.

consume() summarizes a whole polling batch; it never schedules simulation. One owner supplies synchronization and a valid nonnull baseline/start. Consumption validates sample/interval order before changing its baseline; returned Tick owns handles and copied records independent of later calls.

Public Functions

inline Accumulator(std::shared_ptr<const Actions::Snapshot> baseline, ObservationClock::time_point start)
inline Tick consume(ObservationClock::time_point until, std::vector<std::shared_ptr<const Actions::Snapshot>> polls)

Declaration: [[nodiscard]]

Tick consume_polls(ObservationClock::time_point until, std::vector<std::shared_ptr<const PollSnapshot>> polls)

Declaration: [[nodiscard]]