ark::pipeline::MessageSynchronizer

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

Helper class for performing basic channel syncrhonization. The user provides the input channels and the is_sync predicate to determine when messages are synchronized. Whenever synchronized messages are found they are published on the output channel. The user can then create a normal subscriber to receive the synchronized messages.

Typedefs

  • using SynchronizerType = SimpleSynchronizer< std::shared_ptr< const Args >… >

  • using IsSyncedFn = typename SynchronizerType::IsSyncedFn

  • using OutputType = std::tuple< std::shared_ptr< const Args >… >

Methods