AdaptiveTCPClient.h

#pragma once
#include <NDEVR/NDEVRCommunicationLogic.h>
#include <NDEVR/String.h>
#include <NDEVR/QueueBuffer.h>
#include <QWebSocket>
#include <QTcpSocket>
#include <QTimer>
namespace NDEVR
{
    class AdaptiveTCPClient : public QObject, public NDEVRCommunicationLogic
    {
        Q_OBJECT
    public:
        explicit AdaptiveTCPClient(QObject* parent = nullptr);
        void connectToServer(const StringView& host, uint04 port);
        virtual uint08 rx(void* socket, NDEVRDataPacket& packet) override;
        virtual uint08 tx(void* socket, NDEVRDataPacket& packet, uint08 size) override;
        virtual void wait(const TimeSpan& span, LogPtr log = nullptr) override;
        void* connectTo(const NDEVRServerInfo& server) override;
        virtual void disconnectFrom(void* socket) override;
        virtual bool isOpen(void* socket = nullptr) const override;
    private slots:
        void onConnected();
        void onReadyRead();
        void onBytesWritten(qint64);
        void onSendTick();
        void onReconnectTimeout();
    protected:
        QTimer reconnectTimer;          
        QTimer m_send_timer;            
        QTcpSocket* m_server_socket;    
    };
}