33 std::size_t callback_counts = 0;
38 combiner.connect_to_sources(src1, src2);
39 combiner.connect_to_sink(snk);
40 snk.set_processing_function(
44 if (i1 != 1)
throw std::domain_error(
"i1 != 1");
45 if (i2 != 2)
throw std::domain_error(
"i2 != 2");
46 if (d1 != 3.14)
throw std::domain_error(
"d1 != 3.14");
55 ASSERT_EQ(2u, callback_counts);
TEST(fkie_message_filters, FifoCombiner)
NotDefaultConstructable< int > int_M
Combine multiple sources into a single one.
Manually operated data source.
Simplified filter with user-defined callback function.
NotDefaultConstructable< double > double_M
PolicyTmpl< IOs... > Policy
Class type of the policy that applies to the combiner.