consume and produce calls do it in-place

1 files changed, 2 insertions, 4 deletions

diff --git a/lib/gras_impl/block_actor.hpp b/lib/gras_impl/block_actor.hpp
index 67e1815..93e3a2f 100644
--- a/lib/gras_impl/block_actor.hpp
+++ b/lib/gras_impl/block_actor.hpp
@@ -104,6 +104,8 @@ struct BlockActor : Apology::Worker
     void output_fail(const size_t index);
     void sort_tags(const size_t index);
     void trim_tags(const size_t index);
+    void produce(const size_t index, const size_t items);
+    void consume(const size_t index, const size_t items);
     GRAS_FORCE_INLINE bool any_inputs_done(void)
     {
         if (this->inputs_done.none() or this->input_queues.all_ready()) return false;
@@ -131,10 +133,6 @@ struct BlockActor : Apology::Worker
     Block::InputItems input_items;
     Block::OutputItems output_items;
 
-    //track work's calls to produce and consume
-    std::vector<size_t> produce_items;
-    std::vector<size_t> consume_items;
-
     //track the subscriber counts
     std::vector<Token> input_tokens;
     std::vector<Token> output_tokens;