CAF
0.17.6
|
Consumes messages from the mailbox. More...
#include <scheduled_actor.hpp>
Public Member Functions | |
intrusive::task_result | operator() (size_t, upstream_queue &, mailbox_element &) |
Consumes upstream messages. | |
intrusive::task_result | operator() (size_t, downstream_queue &, stream_slot slot, policy::downstream_messages::nested_queue_type &, mailbox_element &) |
Consumes downstream messages. | |
template<class Queue > | |
intrusive::task_result | operator() (size_t, Queue &, mailbox_element &x) |
intrusive::task_result | operator() (mailbox_element &x) |
Public Attributes | |
scheduled_actor * | self |
size_t & | handled_msgs |
size_t | max_throughput |
Consumes messages from the mailbox.