class PendingTransactionsMessageSender {

  public void sendTransactionsToPeers() {
    StreamSupport.stream(transactionTracker.getEthPeersWithUnsentTransactions().spliterator(), true)
        .parallel()
        .forEach(this::sendTransactionsToPeer);
  }

  public  PendingTransactionsMessageSender(final PeerPendingTransactionTracker transactionTracker);

}