Commit 174071fd authored by Dominik Charousset's avatar Dominik Charousset

Remove outbound path unconditionally on drop msg

(cherry picked from commit 538ee173)
parent 33c2789f
......@@ -113,7 +113,8 @@ void stream_manager::handle(stream_slots slots, upstream_msg::ack_batch& x) {
void stream_manager::handle(stream_slots slots, upstream_msg::drop&) {
CAF_LOG_TRACE(CAF_ARG(slots));
out().close(slots.receiver);
error reason;
out().remove_path(slots.receiver, reason, false);
}
void stream_manager::handle(stream_slots slots, upstream_msg::forced_drop& x) {
......
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