@Test public void doesNotInvokeDelegateIfNoValidTimestamps() { Map<Long, Long> result = preStartHandlingService.get(TWO_INVALID_TIMESTAMPS); assertThat(result).containsOnly( Maps.immutableEntry(ZERO_TIMESTAMP, BEFORE_TIME_TIMESTAMP), Maps.immutableEntry(NEGATIVE_TIMESTAMP, BEFORE_TIME_TIMESTAMP)); }
@CheckForNull @Override public Long get(long startTimestamp) { return AtlasFutures.getUnchecked(getInternal(startTimestamp, synchronousAsyncTransactionService)); }
PreStartHandlingTransactionService implements TransactionService { @CheckForNull @Override public Long get(long startTimestamp) { return AtlasFutures.getUnchecked(getInternal(startTimestamp, synchronousAsyncTransactionService)); } }
PreStartHandlingTransactionService implements TransactionService { @CheckForNull @Override public Long get(long startTimestamp) { return AtlasFutures.getUnchecked(getInternal(startTimestamp, synchronousAsyncTransactionService)); } PreStartHandlingTransactionService(TransactionService delegate); }
PreStartHandlingTransactionService implements TransactionService { @CheckForNull @Override public Long get(long startTimestamp) { return AtlasFutures.getUnchecked(getInternal(startTimestamp, synchronousAsyncTransactionService)); } PreStartHandlingTransactionService(TransactionService delegate); @CheckForNull @Override Long get(long startTimestamp); @Override Map<Long, Long> get(Iterable<Long> startTimestamps); @Override ListenableFuture<Long> getAsync(long startTimestamp); @Override ListenableFuture<Map<Long, Long>> getAsync(Iterable<Long> startTimestamps); @Override void putUnlessExists(long startTimestamp, long commitTimestamp); @Override void close(); }
PreStartHandlingTransactionService implements TransactionService { @CheckForNull @Override public Long get(long startTimestamp) { return AtlasFutures.getUnchecked(getInternal(startTimestamp, synchronousAsyncTransactionService)); } PreStartHandlingTransactionService(TransactionService delegate); @CheckForNull @Override Long get(long startTimestamp); @Override Map<Long, Long> get(Iterable<Long> startTimestamps); @Override ListenableFuture<Long> getAsync(long startTimestamp); @Override ListenableFuture<Map<Long, Long>> getAsync(Iterable<Long> startTimestamps); @Override void putUnlessExists(long startTimestamp, long commitTimestamp); @Override void close();  }