32 std::size_t callback_counts = 0;
39 [&](
const int_M& i) ->
bool 42 if (i != 42)
throw std::domain_error(
"i != 42");
46 snk2.set_processing_function(
50 if (d != 3.14)
throw std::domain_error(
"d != 3.14");
55 div.connect_to_sinks(snk1, snk2);
57 ASSERT_EQ(2u, callback_counts);
void set_processing_function(const ProcessingFunction &f) noexcept
Set the user-defined processing function.
Split an N-ary source into N unary ones.
void chain(Filter1 &flt1, Filter2 &flt2, MoreFilters &... filters) noexcept
Convenience function to chain multiple filters.
TEST(fkie_message_filters, Divider)
NotDefaultConstructable< int > int_M
Manually operated data source.
Simplified filter with user-defined callback function.
NotDefaultConstructable< double > double_M