@Test public void enqueueingTokensEnqueuedSinglyAllEventuallyCaptured() { setupTokenCollectingTimeLock(); tokenList.forEach(token -> unlocker.enqueue(ImmutableSet.of(token))); verifyTryUnlockAttemptedAtLeastOnce(); assertAllTokensEventuallyUnlocked(); }
@Override @SuppressWarnings("FutureReturnValueIgnored") public void enqueue(Set<LockToken> tokens) { autobatcher.apply(tokens); }
AsyncTimeLockUnlocker implements TimeLockUnlocker, AutoCloseable { @Override @SuppressWarnings("FutureReturnValueIgnored") public void enqueue(Set<LockToken> tokens) { autobatcher.apply(tokens); } }
AsyncTimeLockUnlocker implements TimeLockUnlocker, AutoCloseable { @Override @SuppressWarnings("FutureReturnValueIgnored") public void enqueue(Set<LockToken> tokens) { autobatcher.apply(tokens); } private  AsyncTimeLockUnlocker(DisruptorAutobatcher<Set<LockToken>, Void> autobatcher); }
AsyncTimeLockUnlocker implements TimeLockUnlocker, AutoCloseable { @Override @SuppressWarnings("FutureReturnValueIgnored") public void enqueue(Set<LockToken> tokens) { autobatcher.apply(tokens); } private  AsyncTimeLockUnlocker(DisruptorAutobatcher<Set<LockToken>, Void> autobatcher); static AsyncTimeLockUnlocker create(TimelockService timelockService); @Override @SuppressWarnings("FutureReturnValueIgnored") void enqueue(Set<LockToken> tokens); @Override void close(); }
AsyncTimeLockUnlocker implements TimeLockUnlocker, AutoCloseable { @Override @SuppressWarnings("FutureReturnValueIgnored") public void enqueue(Set<LockToken> tokens) { autobatcher.apply(tokens); } private  AsyncTimeLockUnlocker(DisruptorAutobatcher<Set<LockToken>, Void> autobatcher); static AsyncTimeLockUnlocker create(TimelockService timelockService); @Override @SuppressWarnings("FutureReturnValueIgnored") void enqueue(Set<LockToken> tokens); @Override void close();  }