code: def init_app(event_source, *, loop=None):
      
  
      dispatcher = Dispatcher(event_source)
  
      # Schedule the dispatcher
      loop.create_task(dispatcher.publish())
  
      app = web.Application(loop=loop)
      app['dispatcher'] = dispatcher
      app.router.add_get(EVENTS_ENDPOINT, websocket_handler)
      return app
docs: Init the application server.
  
      Return:
          An aiohttp application.