Implementation of client-side direct connection. More...
#include <eagine/message_bus/direct.hpp>
Public Member Functions | |
| auto | is_usable () -> bool final |
| Checks if the connection is in usable state. | |
| auto | update () -> bool final |
| Updates the internal state of the connection (called repeatedly). More... | |
| auto | send (message_id msg_id, const message_view &message) -> bool final |
| Sent a message with the specified id. More... | |
| auto | fetch_messages (connection::fetch_handler handler) -> bool final |
| Fetch all enqueued messages that have been received since last fetch. More... | |
| void | cleanup () final |
| Cleans up the connection before destroying it. | |
Public Member Functions inherited from eagine::msgbus::direct_connection_info< connection > | |
| auto | kind () -> connection_kind final |
| auto | addr_kind () -> connection_addr_kind final |
| auto | type_id () -> identifier final |
Public Member Functions inherited from eagine::msgbus::connection | |
| virtual auto | max_data_size () -> valid_if_positive< span_size_t > |
| Returns the maximum data block size in bytes that can be sent. | |
Public Member Functions inherited from eagine::interface< connection_info > | |
| constexpr | interface (const interface &)=delete |
| Not copyable. | |
| auto | operator= (interface &&)=delete |
| Not move assignable. | |
| auto | operator= (const interface &)=delete |
| Not copy assignable. | |
Additional Inherited Members | |
Public Types inherited from eagine::msgbus::connection | |
| using | fetch_handler = callable_ref< bool(message_id, message_age, const message_view &)> |
| Alias for fetch handler callable reference type. | |
Protected Member Functions inherited from eagine::interface< connection_info > | |
| constexpr | interface () noexcept=default |
| Default constructible by derived. | |
| constexpr | interface (interface &&) noexcept=default |
| Move constructible by derived. | |
Implementation of client-side direct connection.
|
inlinefinalvirtual |
Fetch all enqueued messages that have been received since last fetch.
Implements eagine::msgbus::connection.
|
inlinefinalvirtual |
Sent a message with the specified id.
Implements eagine::msgbus::connection.
|
inlinefinalvirtual |
Updates the internal state of the connection (called repeatedly).
Reimplemented from eagine::msgbus::connection.