rapidsmpf: /__w/rapidsmpf/rapidsmpf/cpp/include/rapidsmpf/streaming/core/node.hpp Source File

 #pragma once


 #include <coro/coro.hpp>


 namespace rapidsmpf::streaming {


 using Node = coro::task<void>;


 void run_streaming_pipeline(std::vector<Node> nodes);


 }  // namespace rapidsmpf::streaming

rapidsmpf::streaming
Definition: packed_data.hpp:12

rapidsmpf::streaming::Node
coro::task< void > Node
Alias for a node in a streaming pipeline.
Definition: node.hpp:18

rapidsmpf::streaming::run_streaming_pipeline
void run_streaming_pipeline(std::vector< Node > nodes)
Runs a list of nodes concurrently and waits for all to complete.