88
99class Provider :
1010 def __init__ (self ):
11- self .msgQueue = []
11+ self .msg_queue = []
1212 self .subscribers = {}
1313
1414 def notify (self , msg ):
15- self .msgQueue .append (msg )
15+ self .msg_queue .append (msg )
1616
1717 def subscribe (self , msg , subscriber ):
1818 if not msg in self .subscribers :
1919 self .subscribers [msg ] = []
20- self .subscribers [msg ].append (subscriber ) # unfair
20+ self .subscribers [msg ].append (subscriber ) # unfair
2121 else :
2222 self .subscribers [msg ].append (subscriber )
2323
24- def unSubscribe (self , msg , subscriber ):
24+ def unsubscribe (self , msg , subscriber ):
2525 self .subscribers [msg ].remove (subscriber )
2626
2727 def update (self ):
28- for msg in self .msgQueue :
28+ for msg in self .msg_queue :
2929 if msg in self .subscribers :
3030 for sub in self .subscribers [msg ]:
3131 sub .run (msg )
32- self .msgQueue = []
32+ self .msg_queue = []
3333
3434
3535class Publisher :
36- def __init__ (self , msgCenter ):
37- self .provider = msgCenter
36+ def __init__ (self , msg_center ):
37+ self .provider = msg_center
3838
3939 def publish (self , msg ):
4040 self .provider .notify (msg )
4141
4242
4343class Subscriber :
44- def __init__ (self , name , msgCenter ):
44+ def __init__ (self , name , msg_center ):
4545 self .name = name
46- self .provider = msgCenter
46+ self .provider = msg_center
4747
4848 def subscribe (self , msg ):
4949 self .provider .subscribe (msg , self )
@@ -53,15 +53,15 @@ def run(self, msg):
5353
5454
5555def main ():
56- messageCenter = Provider ()
56+ message_center = Provider ()
5757
58- fftv = Publisher (messageCenter )
58+ fftv = Publisher (message_center )
5959
60- jim = Subscriber ("jim" , messageCenter )
60+ jim = Subscriber ("jim" , message_center )
6161 jim .subscribe ("cartoon" )
62- jack = Subscriber ("jack" , messageCenter )
62+ jack = Subscriber ("jack" , message_center )
6363 jack .subscribe ("music" )
64- gee = Subscriber ("gee" , messageCenter )
64+ gee = Subscriber ("gee" , message_center )
6565 gee .subscribe ("movie" )
6666
6767 fftv .publish ("cartoon" )
@@ -73,7 +73,7 @@ def main():
7373 fftv .publish ("movie" )
7474 fftv .publish ("blank" )
7575
76- messageCenter .update ()
76+ message_center .update ()
7777
7878
7979if __name__ == "__main__" :
0 commit comments