Commit e03c5153 authored by Dominik Charousset's avatar Dominik Charousset

Implement missing callback logic

parent 32fa79e8
...@@ -55,6 +55,8 @@ public: ...@@ -55,6 +55,8 @@ public:
CAF_ASSERT(buf.empty()); CAF_ASSERT(buf.empty());
--demand; --demand;
out.on_next(item); out.on_next(item);
if (when_consumed_some)
ctx->delay(when_consumed_some);
} else { } else {
buf.push_back(item); buf.push_back(item);
} }
...@@ -120,6 +122,8 @@ public: ...@@ -120,6 +122,8 @@ public:
out.on_complete(); out.on_complete();
out = nullptr; out = nullptr;
do_dispose(); do_dispose();
} else if (got_some && when_consumed_some) {
ctx->delay(when_consumed_some);
} }
} }
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment