OscReceiver.h

#pragma once
 
#include <functional>
#include <memory>
#include <vector>
#include <oscpkt.hh>
 
class UdpServer;
namespace std {
        class thread;
};
class OscReceiver{
public:
        OscReceiver();
        OscReceiver(int port, std::function<void(oscpkt::Message* msg, const char* addr, void* arg)> on_receive, void* callbackArg = nullptr);
        ~OscReceiver();

        void setup(int port, std::function<void(oscpkt::Message* msg, const char* addr, void* arg)> on_receive, void* callbackArg = nullptr);
 
private:
        bool lShouldStop = false;
 
        volatile bool waitingForMessage = false;
        int waitForMessage(int timeout_ms);
 
        std::unique_ptr<UdpServer> socket;
        std::unique_ptr<std::thread> receive_task;
 
        void receive_task_func();
 
        std::unique_ptr<oscpkt::PacketReader> pr;
        std::vector<char> inBuffer;
 
        std::function<void(oscpkt::Message* msg, const char* addr, void* arg)> on_receive;
        void* onReceiveArg = nullptr;
};