Lines Matching refs:test_push_receiver
34 using test_push_receiver = oneapi::tbb::flow::queue_node<V>; variable
80 …is_default_constructible<V>::value, std::vector<V>>::type get_values( test_push_receiver<V>& rr ) { in get_values()
91 …is_default_constructible<V>::value, std::vector<V>>::type get_values( test_push_receiver<V>& rr ) { in get_values()
479 std::vector<std::unique_ptr<test_push_receiver<OutputType>>> receiver_nodes; in test_forwarding()
482 receiver_nodes.emplace_back(new test_push_receiver<OutputType>(g)); in test_forwarding()
505 test_push_receiver<int> suc_node1(g); in test_forwarding_single_push()
506 test_push_receiver<int> suc_node2(g); in test_forwarding_single_push()
558 test_push_receiver<int> suc_node1(g); in test_copy_ctor()
559 test_push_receiver<int> suc_node2(g); in test_copy_ctor()
591 test_push_receiver<int> suc_node1(g); in test_copy_ctor_for_buffering_nodes()
592 test_push_receiver<int> suc_node2(g); in test_copy_ctor_for_buffering_nodes()
682 test_push_receiver<int> suc_node(g); in test_concurrency()
700 test_push_receiver<int> suc_node(g); in test_rejecting()
722 test_push_receiver<CountingBody> suc_node(g); in test_output_input_class()
741 test_push_receiver<Output> suc_node(g); in test_output_class()