class Source:

    def __init__(self):
        self.flag = asyncio.Event()
self.output = asyncio.Queue()

def start(self):
    self.flag.set()

def stop(self):
    pass
How do I connect asyncio.coroutines that continually produce and consume data?