8 #ifndef OCM_DAQ_TEST_ASYNC_OP_BASE_HPP_
9 #define OCM_DAQ_TEST_ASYNC_OP_BASE_HPP_
12 #include <gmock/gmock.h>
13 #include <gtest/gtest.h>
14 #include <log4cplus/logger.h>
15 #include <boost/asio/io_context.hpp>
29 *result_listener <<
"where the id is" << (arg->getId());
30 return arg && arg->getId() == id;
50 std::shared_ptr<daq::ObservableStatus>
m_status;
64 void SetUp()
override;
67 template<
class SourceType>
68 std::vector<daq::Source<SourceType>>
70 std::vector<daq::Source<SourceType>> dest;
71 dest.reserve(sources.size());
72 std::transform(std::make_move_iterator(sources.begin()), std::make_move_iterator(sources.end()),
74 return daq::Source<SourceType>{std::move(s)};
82 #endif // #ifndef OCM_DAQ_TEST_ASYNC_OP_BASE_HPP_