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

 #pragma once


 #include <coro/coro.hpp>


 namespace rapidsmpf::streaming {


 using Actor = coro::task<void>;


 void run_actor_network(std::vector<Actor> actors);


 }  // namespace rapidsmpf::streaming

rapidsmpf::streaming
Definition: packed_data.hpp:12

rapidsmpf::streaming::Actor
coro::task< void > Actor
Alias for an actor in a streaming graph.
Definition: actor.hpp:18

rapidsmpf::streaming::run_actor_network
void run_actor_network(std::vector< Actor > actors)
Runs a list of actors concurrently and waits for all to complete.