fanout.hpp

 
#pragma once
 
#include <rapidsmpf/streaming/core/actor.hpp>
#include <rapidsmpf/streaming/core/channel.hpp>
#include <rapidsmpf/streaming/core/context.hpp>
 
namespace rapidsmpf::streaming::actor {
 
enum class FanoutPolicy : std::uint8_t {
    BOUNDED,
 
    UNBOUNDED,
};
 
Actor fanout(
    std::shared_ptr<Context> ctx,
    std::shared_ptr<Channel> ch_in,
    std::vector<std::shared_ptr<Channel>> chs_out,
    FanoutPolicy policy
);
 
}  // namespace rapidsmpf::streaming::actor