-
Notifications
You must be signed in to change notification settings - Fork 0
/
Communicator.h
36 lines (29 loc) · 971 Bytes
/
Communicator.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
#pragma once
#include <vector>
#include "Observer.h"
using ObserverContainer = std::vector<Observer*>;
class Communicator{
public:
~Communicator(){ m_observers.clear(); }
bool AddObserver(Observer* l_observer){
if (HasObserver(l_observer)){ return false; }
m_observers.emplace_back(l_observer);
return true;
}
bool RemoveObserver(Observer* l_observer){
auto observer = std::find_if(m_observers.begin(), m_observers.end(),
[&l_observer](Observer* o){ return o == l_observer; });
if (observer == m_observers.end()){ return false; }
m_observers.erase(observer);
return true;
}
bool HasObserver(const Observer* l_observer){
return (std::find_if(m_observers.begin(), m_observers.end(),
[&l_observer](Observer* o){ return o == l_observer; }) != m_observers.end());
}
void Broadcast(const Message& l_msg){
for(auto& itr : m_observers){ itr->Notify(l_msg); }
}
private:
ObserverContainer m_observers;
};