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();
+    }
   };
 
 }