CObserver.cpp

Go to the documentation of this file.

/* +------------------------------------------------------------------------+
   |                     Mobile Robot Programming Toolkit (MRPT)            |
   |                          https://www.mrpt.org/                         |
   |                                                                        |
   | Copyright (c) 2005-2020, Individual contributors, see AUTHORS file     |
   | See: https://www.mrpt.org/Authors - All rights reserved.               |
   | Released under BSD License. See: https://www.mrpt.org/License          |
   +------------------------------------------------------------------------+ */

#include "system-precomp.h"  // Precompiled headers

#include <mrpt/system/CObservable.h>
#include <mrpt/system/CObserver.h>

using namespace mrpt::system;
using namespace std;

CObserver::CObserver() = default;
CObserver::~CObserver()
{
    while (!m_subscribed.empty()) this->observeEnd(**m_subscribed.begin());
}

/** Starts the subscription of this observer to the given object.  \sa
 * observeEnd  */
void CObserver::observeBegin(CObservable& obj)
{
    m_subscribed.insert(&obj);
    obj.internal_observer_begin(this);
}

/** Ends the subscription of this observer to the given object (note that there
is no need to call this method, since the destruction of the first of
observer/observed will put an end to the process
\sa observeBegin  */
void CObserver::observeEnd(CObservable& obj)
{
    auto it = m_subscribed.find(&obj);
    if (it != m_subscribed.end())
    {
        (*it)->internal_observer_end(this);
        m_subscribed.erase(it);
    }
}

// Redirect the notification to the user virtual method:
void CObserver::internal_on_event(const mrptEvent& e) { this->OnEvent(e); }