mqtt_cpp
Public Member Functions | List of all members
MQTT_NS::tcp_endpoint< Socket, Strand > Class Template Reference

#include <tcp_endpoint.hpp>

Inheritance diagram for MQTT_NS::tcp_endpoint< Socket, Strand >:
Inheritance graph
[legend]
Collaboration diagram for MQTT_NS::tcp_endpoint< Socket, Strand >:
Collaboration graph
[legend]

Public Member Functions

template<typename... Args>
 tcp_endpoint (as::io_context &ioc, Args &&... args)
 
MQTT_ALWAYS_INLINE void async_read (as::mutable_buffer buffers, std::function< void(error_code, std::size_t)> handler) override final
 
MQTT_ALWAYS_INLINE void async_write (std::vector< as::const_buffer > buffers, std::function< void(error_code, std::size_t)> handler) override final
 
MQTT_ALWAYS_INLINE std::size_t write (std::vector< as::const_buffer > buffers, boost::system::error_code &ec) override final
 
MQTT_ALWAYS_INLINE void post (std::function< void()> handler) override final
 
MQTT_ALWAYS_INLINE as::ip::tcp::socket::lowest_layer_type & lowest_layer () override final
 
MQTT_ALWAYS_INLINE any native_handle () override final
 
MQTT_ALWAYS_INLINE void close (boost::system::error_code &ec) override final
 
MQTT_ALWAYS_INLINE as::executor get_executor () override final
 
auto & socket ()
 
auto const & socket () const
 
template<typename... Args>
void set_option (Args &&... args)
 
template<typename... Args>
void async_accept (Args &&... args)
 
- Public Member Functions inherited from MQTT_NS::socket
virtual ~socket ()=default
 

Constructor & Destructor Documentation

◆ tcp_endpoint()

template<typename Socket , typename Strand >
template<typename... Args>
MQTT_NS::tcp_endpoint< Socket, Strand >::tcp_endpoint ( as::io_context &  ioc,
Args &&...  args 
)
inline

Member Function Documentation

◆ async_accept()

template<typename Socket , typename Strand >
template<typename... Args>
void MQTT_NS::tcp_endpoint< Socket, Strand >::async_accept ( Args &&...  args)
inline

◆ async_read()

template<typename Socket , typename Strand >
MQTT_ALWAYS_INLINE void MQTT_NS::tcp_endpoint< Socket, Strand >::async_read ( as::mutable_buffer  buffers,
std::function< void(error_code, std::size_t)>  handler 
)
inlinefinaloverridevirtual

Implements MQTT_NS::socket.

◆ async_write()

template<typename Socket , typename Strand >
MQTT_ALWAYS_INLINE void MQTT_NS::tcp_endpoint< Socket, Strand >::async_write ( std::vector< as::const_buffer >  buffers,
std::function< void(error_code, std::size_t)>  handler 
)
inlinefinaloverridevirtual

Implements MQTT_NS::socket.

◆ close()

template<typename Socket , typename Strand >
MQTT_ALWAYS_INLINE void MQTT_NS::tcp_endpoint< Socket, Strand >::close ( boost::system::error_code &  ec)
inlinefinaloverridevirtual

Implements MQTT_NS::socket.

◆ get_executor()

template<typename Socket , typename Strand >
MQTT_ALWAYS_INLINE as::executor MQTT_NS::tcp_endpoint< Socket, Strand >::get_executor ( )
inlinefinaloverridevirtual

Implements MQTT_NS::socket.

◆ lowest_layer()

template<typename Socket , typename Strand >
MQTT_ALWAYS_INLINE as::ip::tcp::socket::lowest_layer_type& MQTT_NS::tcp_endpoint< Socket, Strand >::lowest_layer ( )
inlinefinaloverridevirtual

Implements MQTT_NS::socket.

◆ native_handle()

template<typename Socket , typename Strand >
MQTT_ALWAYS_INLINE any MQTT_NS::tcp_endpoint< Socket, Strand >::native_handle ( )
inlinefinaloverridevirtual

Implements MQTT_NS::socket.

◆ post()

template<typename Socket , typename Strand >
MQTT_ALWAYS_INLINE void MQTT_NS::tcp_endpoint< Socket, Strand >::post ( std::function< void()>  handler)
inlinefinaloverridevirtual

Implements MQTT_NS::socket.

◆ set_option()

template<typename Socket , typename Strand >
template<typename... Args>
void MQTT_NS::tcp_endpoint< Socket, Strand >::set_option ( Args &&...  args)
inline

◆ socket() [1/2]

template<typename Socket , typename Strand >
auto& MQTT_NS::tcp_endpoint< Socket, Strand >::socket ( )
inline

◆ socket() [2/2]

template<typename Socket , typename Strand >
auto const& MQTT_NS::tcp_endpoint< Socket, Strand >::socket ( ) const
inline

◆ write()

template<typename Socket , typename Strand >
MQTT_ALWAYS_INLINE std::size_t MQTT_NS::tcp_endpoint< Socket, Strand >::write ( std::vector< as::const_buffer >  buffers,
boost::system::error_code &  ec 
)
inlinefinaloverridevirtual

Implements MQTT_NS::socket.


The documentation for this class was generated from the following file: