public boolean firedWithin(long duration, TimeUnit unit) {
      try {
        return latch.await(duration, unit);
      } catch (InterruptedException e) {
        throw Throwables.propagate(e);
      }
    }
See SlotZNode; some tests (and the setup) are c/p-ed or modified from Curator.
llap-client/src/test/org/apache/hadoop/hive/llap/registry/impl/TestSlotZnode.java