void (CancellablePromise<?> promise, String error) { try { promise.blockingGet(100, TimeUnit.MILLISECONDS); } catch (Throwable throwable) { throw new AssertionError(error, throwable); } finally { promise.cancel(); } }