x

PegaSysEng · Apr 20, 2019 · fcc06e6 · fcc06e6
1 parent f114ed9
commit fcc06e6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...th/src/main/java/tech/pegasys/pantheon/ethereum/eth/transactions/PendingTransactions.java b/...th/src/main/java/tech/pegasys/pantheon/ethereum/eth/transactions/PendingTransactions.java
@@ -105,15 +105,15 @@ public PendingTransactions(
     timerUtil.setPeriodic(transactionEvictionIntervalMs, this::evictOldTransactions);
   }
 
-  private boolean filterStream(TransactionInfo transaction) {
+  private boolean applyEvictionThreshold(final TransactionInfo transaction) {
     final long now = System.currentTimeMillis();
     return now - transaction.getAddedToPoolAt().getEpochSecond() > transactionEvictionIntervalMs;
   }
 
   private void evictOldTransactions() {
     synchronized (pendingTransactions) {
       final List<TransactionInfo> transactionsToRemove =
-          prioritizedTransactions.stream().filter(this::filterStream).collect(toList());
+          prioritizedTransactions.stream().filter(this::applyEvictionThreshold).collect(toList());
       transactionsToRemove.forEach(transaction -> removeTransaction(transaction.getTransaction()));
     }
   }