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
37
38
39
40
41
42
|
# Observable Mixin
#
# Observers must respond to update
module Observable
def add_observer(observer)
@observer_peers = [] unless @observer_peers
unless defined? observer.update
raise NameError, "observer needs to respond to `update'"
end
@observer_peers.push observer
end
def delete_observer(observer)
@observer_peers.delete observer if @observer_peers
end
def delete_observers
@observer_peers.clear if @observer_peers
end
def count_observers
if @observer_peers
@observer_peers.size
else
0
end
end
def changed(state=true)
@observer_state = state
end
def changed?
@observer_state
end
def notify_observers(*arg)
if @observer_state
if @observer_peers
for i in @observer_peers
i.update(*arg)
end
end
@observer_state = false
end
end
end
|
