accept.h

Go to the documentation of this file.

 
#ifndef QB_IO_ASYNC_PROTOCOL_ACCEPT_H
#define QB_IO_ASYNC_PROTOCOL_ACCEPT_H
 
namespace qb::io::protocol {

template <typename _IO_, typename _Socket>
class accept : public async::AProtocol<_IO_> {
public:
    using message = _Socket; 

    accept() = delete;

    accept(_IO_ &io) noexcept
        : async::AProtocol<_IO_>(io) {}

    std::size_t
    getMessageSize() noexcept final {
        return static_cast<size_t>(this->_io.getAccepted().is_open());
    }

    void
    onMessage(std::size_t /*size*/) noexcept final { // size is unused
        this->_io.on(std::move(this->_io.getAccepted()));
    }

    void
    reset() noexcept final {}
};
 
} // namespace qb::io::protocol
 
#endif // QB_IO_ASYNC_PROTOCOL_ACCEPT_H