Commit 3f7a252d authored by Dominik Charousset's avatar Dominik Charousset

Close slots individually in close()

parent 4f917888
......@@ -113,12 +113,9 @@ bool downstream_manager::clean(stream_slot slot) const noexcept {
void downstream_manager::close() {
CAF_LOG_TRACE("");
if (clean()) {
for_each_path([&](outbound_path& x) { about_to_erase(&x, false, nullptr); });
clear_paths();
} else {
for_each_path([&](outbound_path& x) { x.closing = true; });
}
auto slots = path_slots();
for (auto slot : slots)
close(slot);
}
void downstream_manager::close(stream_slot slot) {
......
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