@Test public void passesThroughGetsOnMultipleValidTimestamps() { Map<Long, Long> result = preStartHandlingService.get(TWO_VALID_TIMESTAMPS); assertThat(result).containsExactly(Maps.immutableEntry(START_TIMESTAMP, COMMIT_TIMESTAMP)); verify(delegate).get(eq(TWO_VALID_TIMESTAMPS)); }
@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();  }