Commit 9e060c37 authored by Dominik Charousset's avatar Dominik Charousset

Support more mailbox types in sync_request_bouncer

parent 11664cbc
...@@ -32,7 +32,8 @@ struct CAF_CORE_EXPORT sync_request_bouncer { ...@@ -32,7 +32,8 @@ struct CAF_CORE_EXPORT sync_request_bouncer {
error rsn; error rsn;
explicit sync_request_bouncer(error r); explicit sync_request_bouncer(error r);
void operator()(const strong_actor_ptr& sender, const message_id& mid) const; void operator()(const strong_actor_ptr& sender, const message_id& mid) const;
void operator()(const mailbox_element& e) const;
intrusive::task_result operator()(const mailbox_element& e) const;
/// Unwrap WDRR queues. Nesting WDRR queues results in a Key/Queue prefix for /// Unwrap WDRR queues. Nesting WDRR queues results in a Key/Queue prefix for
/// each layer of nesting. /// each layer of nesting.
......
...@@ -42,8 +42,10 @@ void sync_request_bouncer::operator()(const strong_actor_ptr& sender, ...@@ -42,8 +42,10 @@ void sync_request_bouncer::operator()(const strong_actor_ptr& sender,
nullptr); nullptr);
} }
void sync_request_bouncer::operator()(const mailbox_element& e) const { intrusive::task_result
sync_request_bouncer::operator()(const mailbox_element& e) const {
(*this)(e.sender, e.mid); (*this)(e.sender, e.mid);
return intrusive::task_result::resume;
} }
} // namespace caf::detail } // namespace caf::detail
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