Class PollingBacklog

Defined in File polling-backlog.h

Class Documentation

class PollingBacklog

Declaration: final

Platform-to-simulation polling batch.

Its owner supplies synchronization. Lockstep permits one completed poll per consumption; Finite permits capacity; Unlimited has no capacity limit. Full batches pause polling, never drop data.

Public Functions

explicit PollingBacklog(PollingOptions options = {})

bool can_poll() const: Declaration: [[nodiscard]]

bool poll_due(ObservationClock::time_point now) const: Declaration: [[nodiscard]]

ObservationClock::time_point next_poll_at() const: Declaration: [[nodiscard]]

inline std::size_t completed_polls() const: Declaration: [[nodiscard]]

void complete(std::shared_ptr<const PollSnapshot> poll, ObservationClock::time_point completed_at)

void complete(std::shared_ptr<const Actions::Snapshot> state, ObservationClock::time_point completed_at)

std::vector<std::shared_ptr<const PollSnapshot>> consume(): Declaration: [[nodiscard]]