server.h

Go to the documentation of this file.

 
#ifndef QB_IO_ASYNC_TCP_SERVER_H
#define QB_IO_ASYNC_TCP_SERVER_H
 
#include "../io_handler.h"
#include "acceptor.h"
 
namespace qb::io::async::tcp {

template <typename _Derived, typename _Session, typename _Prot>
class server
    : public acceptor<server<_Derived, _Session, _Prot>, _Prot>
    , public io_handler<_Derived, _Session> {
    using acceptor_type = acceptor<server<_Derived, _Session, _Prot>,
                                   _Prot>; 
 
public:
    server() = default;

    void
    on(typename acceptor_type::accepted_socket_type &&new_io) {
        this->registerSession(
            std::forward<typename acceptor_type::accepted_socket_type>(new_io));
    }

    void
    on(event::disconnected &&) {
        // throw std::runtime_error("Server had been disconnected");
    }
};
 
} // namespace qb::io::async::tcp
 
#endif // QB_IO_ASYNC_TCP_SERVER_H