|
HLCC Documentation 2.2.0
|
#include <observablePublisher.hpp>
Public Member Functions | |
| ObservablePublisher (std::unique_ptr<::elt::mal::ps::Publisher< T > > malpub, bool use_malpub=true) | |
| void | AddObserver (ObsCallback observer_function) |
| void | AddObserver (ObsCallbackWithTimestamp observer_function) |
| void | AddObserver (ObsCallbackWithDpQuality observer_function) |
| void | AddObserver (ObsCallbackWithTimestampAndDpQuality observer_function) |
| std::shared_ptr< T > | createDataEntity () |
| PublishingTimeElapsed | Publish (const T &data, const std::chrono::milliseconds &timeout, const taiclock::TaiClock::time_point ×tamp=taiclock::TaiClock::now(), const elt::oldb::CiiOldbDpQuality &dp_quality=elt::oldb::CiiOldbDpQuality::OK) const |
We use ObservablePublisher to publish data both on CII pub-sub, and also to OLDB using lambdas that access all or parts of the pub/sub data.
|
explicit |
| malpub | The MAL publisher to which we delegate. |
| use_malpub | If false, then malpub does not get used for publishing, but possibly still gets used in method createDataEntity(). The idea is to suppress publishing in certain cases, where still ObservablePublisher should be used. |
| void hlcc::oldbmux::ObservablePublisher< T >::AddObserver | ( | ObsCallback | observer_function | ) |
| void hlcc::oldbmux::ObservablePublisher< T >::AddObserver | ( | ObsCallbackWithDpQuality | observer_function | ) |
| void hlcc::oldbmux::ObservablePublisher< T >::AddObserver | ( | ObsCallbackWithTimestamp | observer_function | ) |
| void hlcc::oldbmux::ObservablePublisher< T >::AddObserver | ( | ObsCallbackWithTimestampAndDpQuality | observer_function | ) |
| std::shared_ptr< T > hlcc::oldbmux::ObservablePublisher< T >::createDataEntity | ( | ) |
| PublishingTimeElapsed hlcc::oldbmux::ObservablePublisher< T >::Publish | ( | const T & | data, |
| const std::chrono::milliseconds & | timeout, | ||
| const taiclock::TaiClock::time_point & | timestamp = taiclock::TaiClock::now(), | ||
| const elt::oldb::CiiOldbDpQuality & | dp_quality = elt::oldb::CiiOldbDpQuality::OK ) const |