remove output tags queue, block directly posts msg downstream

1 files changed, 2 insertions, 12 deletions

diff --git a/lib/block_task.cpp b/lib/block_task.cpp
index 5c2137c..4acc1b9 100644
--- a/lib/block_task.cpp
+++ b/lib/block_task.cpp
@@ -181,7 +181,9 @@ void ElementImpl::handle_task(const tsbe::TaskInterface &task_iface)
     work_noutput_items = num_output_items;
     if (this->enable_fixed_rate) work_noutput_items = std::min(
         work_noutput_items, myulround((num_input_items)*this->relative_rate));
+    this->work_task_iface = task_iface;
     const int ret = block_ptr->Work(this->input_items, this->output_items);
+    this->work_task_iface.reset();
     const size_t noutput_items = size_t(ret);
 
     if (ret == Block::WORK_DONE)
@@ -278,18 +280,6 @@ void ElementImpl::handle_task(const tsbe::TaskInterface &task_iface)
     }
 
     //------------------------------------------------------------------
-    //-- now commit all tags in the output queue to the downstream
-    //------------------------------------------------------------------
-    for (size_t i = 0; i < num_outputs; i++)
-    {
-        BOOST_FOREACH(const Tag &t, this->output_tags[i])
-        {
-            task_iface.post_downstream(i, t);
-        }
-        this->output_tags[i].clear();
-    }
-
-    //------------------------------------------------------------------
     //-- Message self based on post-work conditions
     //------------------------------------------------------------------
     this->conclusion(task_iface, inputs_done);