mirrors/bitcoinj
1
0
Fork 0
mirror of https://github.com/bitcoinj/bitcoinj.git synced 2025-03-10 09:20:04 +01:00
Code Issues Projects Releases Packages Wiki Activity

ForwardingService: use awaitRelayed() without extra thenApply() in coinForwardingListener()

Browse source
This commit is contained in:
Sean Gilligan 2023-03-27 12:18:54 -07:00 • committed by Andreas Schildbach
parent 8f504d3795
commit 1b5fdcaa77
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
examples/src/main/java/org/bitcoinj/examples/ForwardingService.java
View file

@ -24,7 +24,6 @@ import org.bitcoinj.base.AddressParser;
import org.bitcoinj.core.Context; import org.bitcoinj.core.Context;
import org.bitcoinj.base.DefaultAddressParser; import org.bitcoinj.base.DefaultAddressParser;
import org.bitcoinj.core.Transaction; import org.bitcoinj.core.Transaction;
import org.bitcoinj.core.TransactionBroadcast;
import org.bitcoinj.kits.WalletAppKit; import org.bitcoinj.kits.WalletAppKit;
import org.bitcoinj.utils.BriefLogFormatter; import org.bitcoinj.utils.BriefLogFormatter;
import org.bitcoinj.wallet.CoinSelection; import org.bitcoinj.wallet.CoinSelection;
@ -169,10 +168,12 @@ public class ForwardingService implements Closeable {
}) })
.thenCompose(broadcast -> { .thenCompose(broadcast -> {
System.out.printf("Transaction %s is signed and is being delivered to %s...\n", broadcast.transaction().getTxId(), network); System.out.printf("Transaction %s is signed and is being delivered to %s...\n", broadcast.transaction().getTxId(), network);
return broadcast.awaitRelayed().thenApply(TransactionBroadcast::transaction); // Wait until peers report they have seen the transaction return broadcast.awaitRelayed(); // Wait until peers report they have seen the transaction
}) })
.thenAccept(tx -> .thenAccept(broadcast ->
System.out.printf("Sent %s onwards and acknowledged by peers, via transaction %s\n", tx.getOutputSum().toFriendlyString(), tx.getTxId()) System.out.printf("Sent %s onwards and acknowledged by peers, via transaction %s\n",
broadcast.transaction().getOutputSum().toFriendlyString(),
broadcast.transaction().getTxId())
); );
} }