AsyncOps.java 文件源码

public void verifyMultiFailure_NoSideEffect() throws KeeperException, InterruptedException {
    List<Op> ops = Arrays.asList(
            Op.create("/multi", new byte[0],
                    Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT),
            Op.delete("/nonexist1", -1));
    zk.multi(ops, this, null);
    latch_await();

    Assert.assertTrue(this.opResults.get(0) instanceof OpResult.ErrorResult);
    Assert.assertNull(zk.exists("/multi", false));
}