Changeset b760ac5 for src/Patterns/Observer/unittests/stubs

Timestamp:

Dec 13, 2011, 12:02:21 PM (14 years ago)

Author:

Frederik Heber <heber@…>

Children:

3324cf

Parents:

d85532

git-author:

Frederik Heber <heber@…> (12/02/11 13:13:44)

git-committer:

Frederik Heber <heber@…> (12/13/11 12:02:21)

Message:

Relay can now also relay notifications.

• NOTE: We do not yet notify the Observables, whose update() we combine, when the Relay is destroyed. They have to signOff before by themselves (or by some other means, e.g. be destroyed before.).

Location:

src/Patterns/Observer/unittests/stubs

Files:

• ObserverStub.cpp (modified) (2 diffs)
• ObserverStub.hpp (modified) (1 diff)

src/Patterns/Observer/unittests/stubs/ObserverStub.cpp

@@ -239 +239 @@
 {}
 
+/************ RelayNotification ***************/
+
+RelayNotification::RelayNotification() :
+    Relay(std::string("RelayTest"))
+{
+  Channels *OurChannel = new Channels();
+  NotificationChannels.insert( std::make_pair(this, OurChannel) );
+  OurChannel->addChannel(NotificationObservable::Operation1Notify);
+  OurChannel->addChannel(NotificationObservable::Operation2Notify);
+}
+
+RelayNotification::~RelayNotification()
+{}
+
 /************ RelayCountObserver ***************/
 
@@ -259 +273 @@
 }
 
+/********* RelayNotificationObserver ***********/
+
+RelayNotificationObserver::RelayNotificationObserver(const Observable * const _relay) :
+  Observer("RelayNotificationObserver"),
+  wasNotified(false),
+  relay(_relay)
+{}
+
+RelayNotificationObserver::~RelayNotificationObserver()
+{}
+
+void RelayNotificationObserver::update(Observable*){}
+void RelayNotificationObserver::subjectKilled(Observable*){}
+void RelayNotificationObserver::recieveNotification(Observable *publisher, Notification_ptr notification){
+  // check that we are not called by the relay itself
+  CPPUNIT_ASSERT(publisher != relay);
+  wasNotified = true;
+}
+

src/Patterns/Observer/unittests/stubs/ObserverStub.hpp

@@ -148 +148 @@
 };
 
+class RelayNotification : public Relay
+{
+public:
+  RelayNotification();
+  ~RelayNotification();
+private:
+};
+
+class RelayNotificationObserver : public Observer {
+public:
+  RelayNotificationObserver(const Observable * const _relay);
+  virtual ~RelayNotificationObserver();
+
+  void update(Observable*);
+  void subjectKilled(Observable*);
+  void recieveNotification(Observable *publisher, Notification_ptr notification);
+
+  bool wasNotified;
+private:
+  const Observable * const relay;
+};
+
 #endif /* OBSERVERSTUB_HPP_ */