mirrors/bitcoinj
1
0
Fork 0
mirror of https://github.com/bitcoinj/bitcoinj.git synced 2025-02-24 22:58:32 +01:00
Code Issues Projects Releases Packages Wiki Activity

TransactionBroadcast: convert EnoughAvailablePeers to lambda

Browse source
This commit is contained in:
Sean Gilligan 2022-07-19 15:25:27 -07:00 • committed by Andreas Schildbach
parent 3786d70de6
commit 3754fa8d99
1 changed files with 4 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
core/src/main/java/org/bitcoinj/core/TransactionBroadcast.java
View file

@ -128,19 +128,8 @@ public class TransactionBroadcast {
public ListenableCompletableFuture<Transaction> broadcast() {
peerGroup.addPreMessageReceivedEventListener(Threading.SAME_THREAD, rejectionListener);
log.info("Waiting for {} peers required for broadcast, we have {} ...", minConnections, peerGroup.getConnectedPeers().size());
peerGroup.waitForPeers(minConnections).thenRunAsync(new EnoughAvailablePeers(), Threading.SAME_THREAD);
return ListenableCompletableFuture.of(future);
}
private class EnoughAvailablePeers implements Runnable {
private Context context;
public EnoughAvailablePeers() {
this.context = Context.get();
}
@Override
public void run() {
final Context context = Context.get();
peerGroup.waitForPeers(minConnections).thenRunAsync(() -> {
Context.propagate(context);
// We now have enough connected peers to send the transaction.
// This can be called immediately if we already have enough. Otherwise it'll be called from a peer
@ -186,7 +175,8 @@ public class TransactionBroadcast {
log.error("Caught exception sending to {}", peer, e);
}
}
}
}, Threading.SAME_THREAD);
return ListenableCompletableFuture.of(future);
}
private int numSeemPeers;