NotificationsManager.h

#include <QThread>
 
#include <functional>
 
namespace kDB
{
  namespace Repository
  {
    class Connection;
    class NotificationsManager : public QThread
    {
      friend class Connection;
      NotificationsManager();
      ~NotificationsManager();
      void start(void* _connection);
      void stop();
    public:
      QMetaObject::Connection listen(const char * _channel, const QObject *receiver, const char *member, Qt::ConnectionType _type = Qt::AutoConnection);
      QMetaObject::Connection listen(const char * _channel, const std::function<void(const QByteArray&)>& _receiver);
      bool unlisten(const char * _channel, const QObject *receiver, const char *member);
      bool unlisten(const QMetaObject::Connection& _connection);
    protected:
      void run() override;
    private:
      struct Private;
      Private* d;
    };
  }
}