113     void operator()( const int &input, counting_gateway_type& gateway) {  in operator ()()
119         if ( input == -1 ) {  in operator ()()
125         gateway.try_put(input);  in operator ()()
138     void operator()( const int &input, counting_gateway_type& gateway ) {  in operator ()()
140         base_type::operator()( input, gateway );  in operator ()()
320         input_type input;  member
354     void submit( const input_type &input, gateway_type& gateway ) {  in submit()  argument
355         work_type work = {input, &gateway};  in submit()
366                 wrapper_helper<output_type, output_type>::copy_value(work.input, output);  in process()
367                 wrapper_helper<output_type, output_type>::check(work.input, output);  in process()
420             g, tbb::flow::unlimited, [](int input) { return input_type(input); }  in run()  argument
424             [&] (const input_type &input, gateway_type& gateway) {  in run()  argument
428                 my_async_activity.submit(input, gateway);  in run()
433             [&](const output_type& input) {  in run()  argument
436                 wrapper_helper<output_type, output_type>::check(input, output);  in run()
540             g, tbb::flow::unlimited, [](int input) { return input_type(input); }  in run()  argument
544             [&](const input_type &input, gateway_type& gateway) {  in run()  argument
548                 my_async_activity.submit(input, gateway);  in run()
623                 g, tbb::flow::unlimited, [](int input) { return input_type(input); }  in operator ()()  argument
627                 [&](const input_type &input, gateway_type& gateway) {  in operator ()()  argument
629                     my_async_activity->submit( input, gateway );  in operator ()()
678         int input;  member
686                 int res = do_work(w.input);  in __anon62ab872d0a02()
732 …node_t node(follows(preds[0], preds[1], preds[2]), unlimited, [&](int input, node_t::gateway_type&…  in test_follows()  argument
733         async_activity.submit(input, &gtw);  in test_follows()
766     node_t node(precedes(successors[0]), unlimited, [&](int input, node_t::gateway_type& gtw) {  in test_precedes()  argument
767         async_activity.submit(input, &gtw);  in test_precedes()