def init_app(event_source, *, loop=None):
    """Init the application server.

    Return:
        An aiohttp application.
    """

    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
def init_app ( event_source , * , loop = None ) : dispatcher = Dispatcher ( event_source ) loop . create_task ( dispatcher . publish ( ) ) app = web . Application ( loop = loop ) app [ 'dispatcher' ] = dispatcher app . router . add_get ( EVENTS_ENDPOINT , websocket_handler ) return app
Init the application server.

    Return:
        An aiohttp application.