|
AsyncBerkeley
Asynchronous Berkeley sockets. Simple.
|
A sender for the poll multiplexer. More...
#include <io/execution/poll_multiplexer.hpp>
Classes | |
| struct | state |
| An operation state for the poll multiplexer. More... | |
Public Member Functions | |
| template<typename Receiver > | |
| auto | connect (Receiver &&receiver) -> state< std::decay_t< Receiver > > |
| Connects the sender to a receiver. | |
Public Attributes | |
| Fn | func |
| The completion handler. | |
| std::shared_ptr< socket_handle > | socket |
| The socket to operate on. | |
| map_type * | demux = nullptr |
| The demultiplexer for the socket. | |
| vector_type * | list = nullptr |
| The list of poll events. | |
| mutex * | mtx = nullptr |
| A mutex for thread safety. | |
| execution_trigger | trigger {} |
| The poll trigger. | |
A sender for the poll multiplexer.
This sender is used to submit I/O operations to the multiplexer. It will complete when the I/O operation is ready.
| Fn | The function type. |
| auto io::execution::basic_poll_multiplexer< Allocator >::sender< Fn >::connect | ( | Receiver && | receiver | ) | -> state< std::decay_t< Receiver > > |
Connects the sender to a receiver.
| receiver | The receiver to connect to. |