Commit 1b95f6d5 authored by Dominik Charousset's avatar Dominik Charousset Committed by Dominik Charousset

Fix handling of final batch when broadcasting

parent 6c50824f
......@@ -113,7 +113,9 @@ private:
p.emit_batch(this->self_, dbs, make_message(std::move(tmp)));
i += dbs;
}
if (std::distance(i, e) > 0) {
if (i == e) {
c.clear();
} else {
c.erase(c.begin(), i);
f(p, c);
}
......
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