From 12c56a0845a7b8e5cbff6ed20eae8b3fa3e26b2d Mon Sep 17 00:00:00 2001
From: Josh Blum
Date: Tue, 6 Nov 2012 21:52:30 -0800
Subject: consume and produce calls do it in-place

---
 lib/gras_impl/block_actor.hpp | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

(limited to 'lib/gras_impl/block_actor.hpp')

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;
-- 
cgit