async def METHOD_NAME(unix_protocol):
    msg = b"*" * (4096*4)
    # If drain calls are not synchronized, then this will raise an
    # AssertionError from within asyncio
    await asyncio.gather(*(unix_protocol.send_raw(msg) for i in range(20)))