Commit aec90867 authored by Dominik Charousset's avatar Dominik Charousset

Fix endless error loop between two stream servers

parent 16b8ba5a
......@@ -103,7 +103,8 @@ void stream_multiplexer::fail(error reason, strong_actor_ptr predecessor,
unsafe_send_as(self_, successor,
make<stream_msg::abort>(current_stream_msg_->sid, reason));
auto rp = self_->make_response_promise();
rp.deliver(std::move(reason));
if (!rp.async())
rp.deliver(std::move(reason));
}
void stream_multiplexer::fail(error reason) {
......
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