def METHOD_NAME(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