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

SendRequest: migrate from ListenableFuture to CompletableFuture

Browse Source
This commit is contained in:
Sean Gilligan 2022-03-07 22:33:27 +01:00 committed by Andreas Schildbach
parent 658514986f
commit 003b6dc52d
1 changed files with 7 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
examples/src/main/java/org/bitcoinj/examples/SendRequest.java
View File

@ -16,11 +16,6 @@
package org.bitcoinj.examples;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.MoreExecutors;
import org.bitcoinj.core.*;
import org.bitcoinj.kits.WalletAppKit;
import org.bitcoinj.params.TestNet3Params;
@ -28,6 +23,7 @@ import org.bitcoinj.wallet.Wallet;
import org.bitcoinj.wallet.Wallet.BalanceType;
import java.io.File;
import java.util.concurrent.CompletableFuture;
/**
* The following example shows you how to create a SendRequest to send coins from a wallet to a given address.
@ -68,21 +64,15 @@ public class SendRequest {
System.out.println("Send money to: " + kit.wallet().currentReceiveAddress().toString());
// Bitcoinj allows you to define a BalanceFuture to execute a callback once your wallet has a certain balance.
// Here we wait until the we have enough balance and display a notice.
// Bitcoinj is using the ListenableFutures of the Guava library. Have a look here for more information: https://github.com/google/guava/wiki/ListenableFutureExplained
ListenableFuture<Coin> balanceFuture = kit.wallet().getBalanceFuture(value, BalanceType.AVAILABLE);
FutureCallback<Coin> callback = new FutureCallback<Coin>() {
@Override
public void onSuccess(Coin balance) {
// Here we wait until we have enough balance and display a notice.
CompletableFuture<Coin> balanceFuture = kit.wallet().getBalanceFuture(value, BalanceType.AVAILABLE);
balanceFuture.whenComplete((balance, throwable) -> {
if (balance != null) {
System.out.println("coins arrived and the wallet now has enough balance");
}
@Override
public void onFailure(Throwable t) {
} else {
System.out.println("something went wrong");
}
};
Futures.addCallback(balanceFuture, callback, MoreExecutors.directExecutor());
});
}
// shutting down