async def METHOD_NAME(unix_protocol, unix_srv):
    unix_protocol.reader.set_exception(
        RuntimeError("Unit test triggered exception")
    )
    with pytest.raises(DisconnectedError):
        await unix_protocol.send_message({"Hello": "World"})
    assert unix_protocol.is_connected() is False