|
libcaf
0.13.2
|
Manages a stream. More...
#include <broker.hpp>
Public Member Functions | |
| scribe (broker *parent, connection_handle hdl) | |
| virtual void | configure_read (receive_policy::config config)=0 |
| Implicitly starts the read loop on first call. | |
| virtual buffer_type & | wr_buf ()=0 |
| Grants access to the output buffer. | |
| virtual void | flush ()=0 |
| Flushes the output buffer, i.e., sends the content of the buffer via the network. | |
| connection_handle | hdl () const |
| void | io_failure (network::operation op) override |
Protected Member Functions | |
| virtual buffer_type & | rd_buf ()=0 |
| new_data_msg & | read_msg () |
| const new_data_msg & | read_msg () const |
| void | remove_from_broker () override |
| message | disconnect_message () override |
| void | consume (const void *data, size_t num_bytes) override |
Protected Member Functions inherited from caf::io::broker::servant | |
| broker * | parent () |
| servant (broker *ptr) | |
| void | set_broker (broker *ptr) |
| void | disconnect (bool invoke_disconnect_message) |
Protected Attributes | |
| connection_handle | m_hdl |
| message | m_read_msg |
Protected Attributes inherited from caf::io::broker::servant | |
| bool | m_disconnected |
| intrusive_ptr< broker > | m_broker |
Manages a stream.
1.8.9.1