···

       
50
       
50
       
 
       
                yield message

     

       
51
       
51
       
 
       


     

       
52
       
52
       
 
       
async def main():

     

       
53
       
53
       
-
       
    manager = Manager()

     

       
54
       
54
       
-
       
    manager.register(RapidFireFeed)

     

       
55
       
55
       
-
       
    manager.register(PopularFeed)

     

       
53
       
53
       
+
       
    firehose_manager = FirehoseManager()

     

       
54
       
54
       
+
       


     

       
55
       
55
       
+
       
    feed_manager = FeedManager()

     

       
56
       
56
       
+
       
    feed_manager.register(RapidFireFeed)

     

       
57
       
57
       
+
       
    feed_manager.register(PopularFeed)

     

       
56
       
58
       
 
       


     

       
57
       
59
       
 
       
    async for commit in firehose_events():

     

       
58
       
58
       
-
       
        manager.process(commit)

     

       
60
       
60
       
+
       
        feed_manager.process(commit)

     

       
59
       
61
       
 
       


     

       
60
       
62
       
 
       
if __name__ == '__main__':

     

       
61
       
63
       
 
       
    asyncio.run(main())

     

···

       
1
       
1
       
-
       
class Manager:

     

       
1
       
1
       
+
       
class FeedManager:

     

       
2
       
2
       
 
       
    def __init__(self):

     

       
3
       
3
       
 
       
        self.feeds = {}

     

       
4
       
4