AsyncOps.java 文件源码

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

    Assert.assertEquals(this.rc, KeeperException.Code.OK.intValue());
    Assert.assertTrue(this.opResults.get(0) instanceof OpResult.CreateResult);
    Assert.assertTrue(this.opResults.get(1) instanceof OpResult.DeleteResult);
}