created API for passive work-flow

1 files changed, 9 insertions, 0 deletions

diff --git a/lib/block_task.cpp b/lib/block_task.cpp
index 5e1db89..d3e12f6 100644
--- a/lib/block_task.cpp
+++ b/lib/block_task.cpp
@@ -233,3 +233,12 @@ void BlockActor::produce(const size_t i, const size_t items)
     const size_t bytes = items*this->output_items_sizes[i];
     buff.length += bytes;
 }
+
+void BlockActor::produce_buffer(const size_t i, const SBuffer &buffer)
+{
+    const size_t items = buffer.length/output_items_sizes[i];
+    this->items_produced[i] += items;
+    InputBufferMessage buff_msg;
+    buff_msg.buffer = buffer;
+    this->post_downstream(i, buff_msg);
+}