Mercurial > hg > orthanc-stone
diff Framework/Messages/MessageBroker.h @ 299:3897f9f28cfa am-callable-and-promise
backup work in progress: updated messaging framework with ICallable
author | am@osimis.io |
---|---|
date | Fri, 14 Sep 2018 16:44:01 +0200 |
parents | 5bd4161bf11b |
children | 99e31898910e |
line wrap: on
line diff
--- a/Framework/Messages/MessageBroker.h Mon Sep 10 12:22:26 2018 +0200 +++ b/Framework/Messages/MessageBroker.h Fri Sep 14 16:44:01 2018 +0200 @@ -21,23 +21,18 @@ #pragma once -#include "../StoneEnumerations.h" - #include "boost/noncopyable.hpp" -#include <map> -#include <list> #include <set> namespace OrthancStone { class IObserver; class IObservable; - class IMessage; /* * This is a central message broker. It keeps track of all observers and knows * when an observer is deleted. - * This way, it can prevent an observable to send a message to a dead observer. + * This way, it can prevent an observable to send a message to a deleted observer. */ class MessageBroker : public boost::noncopyable { @@ -56,7 +51,10 @@ activeObservers_.erase(&observer); } - void EmitMessage(IObservable& from, std::set<IObserver*> observers, const IMessage& message); + bool IsActive(IObserver* observer) + { + return activeObservers_.find(observer) != activeObservers_.end(); + } }; }