thread-listener.hpp

#pragma once
 
#include "listener.hpp"
 
#include <any>
#include <cassert>
#include <map>
#include <mutex>
#include <string>
#include <string_view>
#include <typeindex>
#include <vector>
 
namespace event {
 
class TOAST_API ThreadListener {
  using callback_t = std::move_only_function<bool(_detail::IEvent&)>;
 
  struct Handle {
    std::type_index type;
    std::string name;
    callback_t callback;
  };
 
  struct {
    std::vector<_detail::IEvent*> event_queue;                
    std::mutex queue_mutex;
    std::map<std::type_index, std::any> recievers;            
    std::multimap<char, Handle, std::greater<>> callbacks;    
    std::atomic<bool>* enabled;                               
  } m;
 
public:
  ThreadListener();
  ThreadListener(bool state);
  ~ThreadListener();

  void clear();

  template<typename TEvent>
  void unsubscribe(std::string_view name) noexcept;

  template<typename TEvent, EventCallback<TEvent&> F>
  void subscribe(std::string name, F&& callback, char priority = 0) noexcept;

  template<typename TEvent, EventCallback<TEvent&> F>
  void subscribe(F&& callback, char priority = 0) noexcept;

  void enabled(bool state);

  [[nodiscard]]
  auto enabled() const -> bool;

  void pollEvents();
 
private:
  template<typename TEvent>
  void listen() noexcept;
};
}
 
#include "thread-listener.inl"