Function recv

src/py/reactpy/tests/test_core/test_serve.py:38–44

()

            raise Exception("Stop running")

    async def recv():
        await sem.acquire()
        try:
            return events_to_inject.pop(0)
        except IndexError:
            # wait forever
            await asyncio.Event().wait()

    return changes, send, recv