Commit b37f3e10 authored by Dominik Charousset's avatar Dominik Charousset

Delegate stream_msg::abort to the policies

parent 8c1611fb
...@@ -96,11 +96,12 @@ auto stream_msg_visitor::operator()(stream_msg::close&) -> result_type { ...@@ -96,11 +96,12 @@ auto stream_msg_visitor::operator()(stream_msg::close&) -> result_type {
auto stream_msg_visitor::operator()(stream_msg::abort& x) -> result_type { auto stream_msg_visitor::operator()(stream_msg::abort& x) -> result_type {
CAF_LOG_TRACE(CAF_ARG(x)); CAF_LOG_TRACE(CAF_ARG(x));
if (i_ == e_) { if (i_ != e_ && self_->current_sender() != nullptr) {
CAF_LOG_DEBUG("received stream_msg::abort for unknown stream"); i_->second->abort(self_->current_sender(), x.reason);
return {sec::unexpected_message, e_}; return {std::move(x.reason), i_};
} }
return {std::move(x.reason), i_}; CAF_LOG_DEBUG("received stream_msg::abort for unknown stream");
return {sec::unexpected_message, e_};
} }
auto stream_msg_visitor::operator()(stream_msg::ack_open& x) -> result_type { auto stream_msg_visitor::operator()(stream_msg::ack_open& x) -> result_type {
......
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