aboutsummaryrefslogtreecommitdiff
path: root/src/FbTk
diff options
context:
space:
mode:
Diffstat (limited to 'src/FbTk')
-rw-r--r--src/FbTk/Subject.cc24
-rw-r--r--src/FbTk/Subject.hh5
2 files changed, 23 insertions, 6 deletions
diff --git a/src/FbTk/Subject.cc b/src/FbTk/Subject.cc
index 961d6a8..a575cfd 100644
--- a/src/FbTk/Subject.cc
+++ b/src/FbTk/Subject.cc
@@ -19,7 +19,7 @@
19// FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER 19// FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
20// DEALINGS IN THE SOFTWARE. 20// DEALINGS IN THE SOFTWARE.
21 21
22// $Id: Subject.cc,v 1.2 2003/08/19 16:03:26 fluxgen Exp $ 22// $Id: Subject.cc,v 1.3 2003/09/08 15:38:46 fluxgen Exp $
23 23
24#include "Subject.hh" 24#include "Subject.hh"
25#include "Observer.hh" 25#include "Observer.hh"
@@ -31,7 +31,7 @@ namespace FbTk {
31 31
32Subject::SubjectList Subject::s_subjectlist; 32Subject::SubjectList Subject::s_subjectlist;
33 33
34Subject::Subject() { 34Subject::Subject():m_notify_mode(false) {
35 s_subjectlist.push_back(this); 35 s_subjectlist.push_back(this);
36} 36}
37 37
@@ -48,14 +48,28 @@ void Subject::attach(Observer *obj) {
48} 48}
49 49
50void Subject::detach(Observer *obj) { 50void Subject::detach(Observer *obj) {
51 m_observerlist.erase(std::remove(m_observerlist.begin(), 51 if (m_notify_mode)
52 m_observerlist.end(), obj), 52 m_dead_observers.push_back(obj);
53 m_observerlist.end()); 53 else {
54 m_observerlist.erase(std::remove(m_observerlist.begin(),
55 m_observerlist.end(), obj),
56 m_observerlist.end());
57 }
54} 58}
55 59
56void Subject::notify() { 60void Subject::notify() {
61 m_notify_mode = true;
57 std::for_each(m_observerlist.begin(), m_observerlist.end(), 62 std::for_each(m_observerlist.begin(), m_observerlist.end(),
58 std::bind2nd(std::mem_fun(&Observer::update), this)); 63 std::bind2nd(std::mem_fun(&Observer::update), this));
64 m_notify_mode = false;
65
66 // remove dead observers
67 if (m_dead_observers.size()) {
68 std::for_each(m_dead_observers.begin(),
69 m_dead_observers.end(),
70 std::bind1st(std::mem_fun(&Subject::detach), this));
71 m_dead_observers.clear();
72 }
59} 73}
60 74
61void Subject::removeObserver(Observer *obj) { 75void Subject::removeObserver(Observer *obj) {
diff --git a/src/FbTk/Subject.hh b/src/FbTk/Subject.hh
index ca8d142..000fc2e 100644
--- a/src/FbTk/Subject.hh
+++ b/src/FbTk/Subject.hh
@@ -19,7 +19,7 @@
19// FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER 19// FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
20// DEALINGS IN THE SOFTWARE. 20// DEALINGS IN THE SOFTWARE.
21 21
22// $Id: Subject.hh,v 1.3 2003/08/19 16:03:52 fluxgen Exp $ 22// $Id: Subject.hh,v 1.4 2003/09/08 15:38:46 fluxgen Exp $
23 23
24#ifndef FBTK_SUBJECT_HH 24#ifndef FBTK_SUBJECT_HH
25#define FBTK_SUBJECT_HH 25#define FBTK_SUBJECT_HH
@@ -44,8 +44,11 @@ public:
44 void notify(); 44 void notify();
45 static void removeObserver(Observer *obs); 45 static void removeObserver(Observer *obs);
46private: 46private:
47 bool m_notify_mode;
48
47 typedef std::list<Observer *> ObserverList; 49 typedef std::list<Observer *> ObserverList;
48 ObserverList m_observerlist; 50 ObserverList m_observerlist;
51 ObserverList m_dead_observers;
49 52
50 typedef std::list<Subject *> SubjectList; 53 typedef std::list<Subject *> SubjectList;
51 static SubjectList s_subjectlist; 54 static SubjectList s_subjectlist;