Commit d2e4180a authored by Dominik Charousset's avatar Dominik Charousset

Fix callback handling in flow::op::mcast

parent d0bdbb04
......@@ -55,6 +55,8 @@ public:
CAF_ASSERT(buf.empty());
--demand;
out.on_next(item);
if (when_consumed_some)
ctx->delay(when_consumed_some);
} else {
buf.push_back(item);
}
......@@ -120,6 +122,8 @@ public:
out.on_complete();
out = nullptr;
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