async def METHOD_NAME(left, right):
    await left.setup()
    await right.setup()
    while True:
        from_left = await left.read(1024 * 1024)
        from_right = await right.read(1024 * 1024)
        if len(from_left.getbuffer()) == 0:
            assert len(from_right.getbuffer()) == 0
            break
        if from_left.getbuffer() != from_right.getbuffer():
            print("break!")
        assert from_left.getbuffer() == from_right.getbuffer()