mythobservable.cpp

Go to the documentation of this file.

#include <QCoreApplication>
#include <QObject>
#include <QMutex>
 
#include "mythobservable.h"
 
MythObservable::~MythObservable()
{
    m_lock->lock();
    m_listeners.clear();
    m_lock->unlock();
    delete m_lock;
    m_lock = nullptr;
}
 
void MythObservable::addListener(QObject *listener)
{
    if (listener)
    {
        QMutexLocker locker(m_lock);
        m_listeners.insert(listener);
    }
}
 
 
void MythObservable::removeListener(QObject *listener)
{
    if (listener)
    {
        QMutexLocker locker(m_lock);
        m_listeners.remove(listener);
        QCoreApplication::removePostedEvents(listener);
    }
}
 
void MythObservable::dispatch(const MythEvent &event)
{
    QMutexLocker locker(m_lock);
 
    for (auto *listener : std::as_const(m_listeners))
        QCoreApplication::postEvent(listener, event.clone());
}