Skip to content

Commit ef4fe34

Browse files
committed
Indentation fix
1 parent ee37556 commit ef4fe34

File tree

1 file changed

+56
-53
lines changed

1 file changed

+56
-53
lines changed

‎publish_subscribe.py‎

Lines changed: 56 additions & 53 deletions
Original file line numberDiff line numberDiff line change
@@ -5,73 +5,76 @@
55
Author: https://github.com/HanWenfang
66
'''
77

8+
89
classProvider:
9-
def__init__(self):
10-
self.msgQueue= []
11-
self.subscribers={}
12-
13-
defnotify(self, msg):
14-
self.msgQueue.append(msg)
15-
16-
defsubscribe(self,msg, subscriber):
17-
ifnotmsginself.subscribers:
18-
self.subscribers[msg] = []
19-
self.subscribers[msg].append(subscriber) #unfair
20-
else:
21-
self.subscribers[msg].append(subscriber)
22-
23-
defunSubscribe(self,msg, subscriber):
24-
self.subscribers[msg].remove(subscriber)
25-
26-
defupdate(self):
27-
formsginself.msgQueue:
28-
ifmsginself.subscribers:
29-
forsubinself.subscribers[msg]:
30-
sub.run(msg)
31-
self.msgQueue= []
10+
def__init__(self):
11+
self.msgQueue= []
12+
self.subscribers={}
13+
14+
defnotify(self, msg):
15+
self.msgQueue.append(msg)
16+
17+
defsubscribe(self, msg, subscriber):
18+
ifnotmsginself.subscribers:
19+
self.subscribers[msg] = []
20+
self.subscribers[msg].append(subscriber) #unfair
21+
else:
22+
self.subscribers[msg].append(subscriber)
23+
24+
defunSubscribe(self, msg, subscriber):
25+
self.subscribers[msg].remove(subscriber)
26+
27+
defupdate(self):
28+
formsginself.msgQueue:
29+
ifmsginself.subscribers:
30+
forsubinself.subscribers[msg]:
31+
sub.run(msg)
32+
self.msgQueue= []
33+
3234

3335
classPublisher:
34-
def__init__(self, msgCenter):
35-
self.provider=msgCenter
36-
37-
defpublish(self, msg):
38-
self.provider.notify(msg)
36+
def__init__(self, msgCenter):
37+
self.provider=msgCenter
38+
39+
defpublish(self, msg):
40+
self.provider.notify(msg)
3941

4042

4143
classSubscriber:
42-
def__init__(self,name,msgCenter):
43-
self.name=name
44-
self.provider=msgCenter
44+
def__init__(self,name,msgCenter):
45+
self.name=name
46+
self.provider=msgCenter
4547

46-
defsubscribe(self, msg):
47-
self.provider.subscribe(msg, self)
48+
defsubscribe(self, msg):
49+
self.provider.subscribe(msg, self)
4850

49-
defrun(self, msg):
50-
print"%s got %s"%(self.name, msg)
51+
defrun(self, msg):
52+
print"%s got %s"%(self.name, msg)
5153

5254

5355
defmain():
54-
messageCenter=Provider()
56+
messageCenter=Provider()
57+
58+
fftv=Publisher(messageCenter)
5559

56-
fftv=Publisher(messageCenter)
60+
jim=Subscriber("jim", messageCenter)
61+
jim.subscribe("cartoon")
62+
jack=Subscriber("jack", messageCenter)
63+
jack.subscribe("music")
64+
gee=Subscriber("gee", messageCenter)
65+
gee.subscribe("movie")
5766

58-
jim=Subscriber("jim", messageCenter)
59-
jim.subscribe("cartoon")
60-
jack=Subscriber("jack", messageCenter)
61-
jack.subscribe("music")
62-
gee=Subscriber("gee", messageCenter)
63-
gee.subscribe("movie")
67+
fftv.publish("cartoon")
68+
fftv.publish("music")
69+
fftv.publish("ads")
70+
fftv.publish("movie")
71+
fftv.publish("cartoon")
72+
fftv.publish("cartoon")
73+
fftv.publish("movie")
74+
fftv.publish("blank")
6475

65-
fftv.publish("cartoon")
66-
fftv.publish("music")
67-
fftv.publish("ads")
68-
fftv.publish("movie")
69-
fftv.publish("cartoon")
70-
fftv.publish("cartoon")
71-
fftv.publish("movie")
72-
fftv.publish("blank")
76+
messageCenter.update()
7377

74-
messageCenter.update()
7578

7679
if__name__=="__main__":
77-
main()
80+
main()

0 commit comments

Comments
(0)