Testing out a Notifier to connect a loop to a separate function

coroutine.py

import asyncio


async def shout(msg):
    print(msg.upper())


class Notifier(object):
    def __init__(self):
        self._listeners = []

    async def add_listener(self, listener):
        self._listeners.append(listener)

    async def emit(self, msg):
        for listener in self._listeners:
            await listener(msg)


async def main():
    notify = Notifier()
    await notify.add_listener(shout)
    while True:
        await notify.emit("New Data")

loop = asyncio.get_event_loop()
loop.run_until_complete(main())