async def METHOD_NAME() -> t.AsyncGenerator[bytes, None]:
    more_body = True
    while more_body:
        message = await receive()
        messages.append(message)
        more_body = message.get("more_body", False)
        yield message.get("body", b"")
    yield b""