ark::pipeline::SimpleSynchronizer

Defined in header “ark/pipeline/message_synchronizer.hh”.

---

Typedefs

• using QueueType = core::CircularBuffer< T >

• using IsSyncedFn = std::function< bool(const Args &…)>

• using OutputCallback = std::function< void(Args…)>

Methods

• SimpleSynchronizer(Config config)

• void push(auto value)

• SynchronizedQueueStatistics statistics()