8
8
9
9
class Provider :
10
10
def __init__ (self ):
11
- self .msgQueue = []
11
+ self .msg_queue = []
12
12
self .subscribers = {}
13
13
14
14
def notify (self , msg ):
15
- self .msgQueue .append (msg )
15
+ self .msg_queue .append (msg )
16
16
17
17
def subscribe (self , msg , subscriber ):
18
18
if not msg in self .subscribers :
19
19
self .subscribers [msg ] = []
20
- self .subscribers [msg ].append (subscriber ) # unfair
20
+ self .subscribers [msg ].append (subscriber ) # unfair
21
21
else :
22
22
self .subscribers [msg ].append (subscriber )
23
23
24
- def unSubscribe (self , msg , subscriber ):
24
+ def unsubscribe (self , msg , subscriber ):
25
25
self .subscribers [msg ].remove (subscriber )
26
26
27
27
def update (self ):
28
- for msg in self .msgQueue :
28
+ for msg in self .msg_queue :
29
29
if msg in self .subscribers :
30
30
for sub in self .subscribers [msg ]:
31
31
sub .run (msg )
32
- self .msgQueue = []
32
+ self .msg_queue = []
33
33
34
34
35
35
class Publisher :
36
- def __init__ (self , msgCenter ):
37
- self .provider = msgCenter
36
+ def __init__ (self , msg_center ):
37
+ self .provider = msg_center
38
38
39
39
def publish (self , msg ):
40
40
self .provider .notify (msg )
41
41
42
42
43
43
class Subscriber :
44
- def __init__ (self , name , msgCenter ):
44
+ def __init__ (self , name , msg_center ):
45
45
self .name = name
46
- self .provider = msgCenter
46
+ self .provider = msg_center
47
47
48
48
def subscribe (self , msg ):
49
49
self .provider .subscribe (msg , self )
@@ -53,15 +53,15 @@ def run(self, msg):
53
53
54
54
55
55
def main ():
56
- messageCenter = Provider ()
56
+ message_center = Provider ()
57
57
58
- fftv = Publisher (messageCenter )
58
+ fftv = Publisher (message_center )
59
59
60
- jim = Subscriber ("jim" , messageCenter )
60
+ jim = Subscriber ("jim" , message_center )
61
61
jim .subscribe ("cartoon" )
62
- jack = Subscriber ("jack" , messageCenter )
62
+ jack = Subscriber ("jack" , message_center )
63
63
jack .subscribe ("music" )
64
- gee = Subscriber ("gee" , messageCenter )
64
+ gee = Subscriber ("gee" , message_center )
65
65
gee .subscribe ("movie" )
66
66
67
67
fftv .publish ("cartoon" )
@@ -73,7 +73,7 @@ def main():
73
73
fftv .publish ("movie" )
74
74
fftv .publish ("blank" )
75
75
76
- messageCenter .update ()
76
+ message_center .update ()
77
77
78
78
79
79
if __name__ == "__main__" :
0 commit comments