Pubsub

Example

pubsub.py
 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
#!/usr/bin/env python3
import asab


class MyApplication(asab.Application):

    async def initialize(self):
        self.PubSub.subscribe("Application.tick!", self.on_tick)
        self.d = DisapearingSubscriber()
        self.d_cnt = 3
        self.PubSub.subscribe("Application.tick!", self.d.on_non_ref)
        self.PubSub.subscribe("Application.tick!", FunctionalSubscriber)


    def on_tick(self, message_name):
        print(message_name)
        self.d_cnt -= 1
        if self.d_cnt == 0:
            self.d = None



class DisapearingSubscriber(object):

    async def on_non_ref(self, message_name):
        print("DisapearingSubscriber: ", message_name)


def FunctionalSubscriber(message_name):
    print("FunctionalSubscriber: ", message_name)



if __name__ == '__main__':
    app = MyApplication()
    app.run()