leaf_actor.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 {
 
 
Actor push_to_channel(
    std::shared_ptr<Context> ctx,
    std::shared_ptr<Channel> ch_out,
    std::vector<Message> messages
);
 
Actor pull_from_channel(
    std::shared_ptr<Context> ctx,
    std::shared_ptr<Channel> ch_in,
    std::vector<Message>& out_messages
);
 
}  // namespace rapidsmpf::streaming::actor