subscription.hpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup  daq_ocm_libdaqif_suppport
 * @copyright 2022 ESO - European Southern Observatory
 *
 * @brief Contains URI support functions for daqif
 */
#ifndef DAQIF_SUBSCRIPTION_HPP_
#define DAQIF_SUBSCRIPTION_HPP_
#include <memory>
 
#include <daqif/uri.hpp>
 
#include <mal/Mal.hpp>
#include <mal/ps/Subscription.hpp>
 
namespace daqif {
 
/**
 * Subscription
 */
template <class TopicType>
struct Subscription {
    std::unique_ptr<elt::mal::ps::Subscriber<TopicType>> subscriber;
    std::unique_ptr<elt::mal::ps::Subscription> subscription;
};
 
/**
 * Builder for Subscription
 */
template <class TopicType, class Func>
auto MakeSubscription(elt::mal::Mal& mal, elt::mal::Uri const& uri, Func&& func)
    -> Subscription<TopicType> {
    auto subscriber = mal.getSubscriber<TopicType>(
        elt::mal::Uri(uri), elt::mal::ps::qos::QoS::DEFAULT, elt::mal::Mal::Properties());
    auto subscription =
        subscriber->subscribeAsync(elt::mal::ps::DataEventFilter<TopicType>::all(), func);
    return {std::move(subscriber), std::move(subscription)};
}
 
} // namespace daqif
#endif // #ifndef DAQIF_SUBSCRIPTION_HPP_