protocol.h

Go to the documentation of this file.

 
#ifndef QB_IO_ASYNC_PROTOCOL_H
#define QB_IO_ASYNC_PROTOCOL_H
 
#include <qb/utility/type_traits.h>
 
namespace qb::io::async {

class IProtocol {
    bool _status = true; 
    bool _should_flush = true; 
public:
    virtual ~IProtocol() = default;

    virtual std::size_t getMessageSize() noexcept = 0;

    virtual void onMessage(std::size_t size) noexcept = 0;

    virtual void reset() noexcept = 0;
 
public:
    [[nodiscard]] bool
    ok() const noexcept {
        return _status;
    }

    void
    not_ok() noexcept {
        _status = false;
    }

    void set_should_flush(bool should_flush) noexcept {
        _should_flush = should_flush;
    }

    bool should_flush() const noexcept {
        return _should_flush;
    }
};

template <typename _IO_>
class AProtocol : public IProtocol {
    friend typename _IO_::base_io_t;
 
 
protected:
    _IO_ &_io; 

    AProtocol() = delete;

    AProtocol(_IO_ &io) noexcept
        : _io(io) {}

    virtual ~AProtocol() = default;
 
    // Pure virtual methods inherited from IProtocol, to be implemented by concrete protocols.

    virtual std::size_t getMessageSize() noexcept = 0;

    virtual void onMessage(std::size_t size) noexcept = 0;

    virtual void reset() noexcept = 0;
 
 
};
 
} // namespace qb::io::async
 
#endif // QB_IO_ASYNC_PROTOCOL_H