libcaf
0.17.1
|
Manages a stream. More...
#include <scribe.hpp>
Public Member Functions | |
scribe (connection_handle conn_hdl) | |
virtual void | configure_read (receive_policy::config config)=0 |
Implicitly starts the read loop on first call. | |
virtual void | ack_writes (bool enable)=0 |
Enables or disables write notifications. | |
virtual std::vector< char > & | wr_buf ()=0 |
Returns the current output buffer. | |
virtual std::vector< char > & | rd_buf ()=0 |
Returns the current input buffer. | |
virtual void | flush ()=0 |
Flushes the output buffer, i.e., sends the content of the buffer via the network. More... | |
bool | consume (execution_unit *, const void *, size_t) override |
void | data_transferred (execution_unit *, size_t, size_t) override |
![]() | |
broker_servant (handle_type x) | |
Protected Member Functions | |
message | detach_message () override |
Additional Inherited Members | |
![]() | |
using | handle_type = Handle |
![]() | |
mailbox_element_vals< SysMsgType > | value_ |
optional< size_t > | activity_tokens_ |
Manages a stream.
|
pure virtual |
Flushes the output buffer, i.e., sends the content of the buffer via the network.
Implemented in caf::io::network::scribe_impl.