mirrors/bitcoinj
1
0
Fork 0
mirror of https://github.com/bitcoinj/bitcoinj.git synced 2024-11-20 10:12:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

BitcoindComparisonTool: migrate from SettableFuture to CompletableFuture

Browse Source
This commit is contained in:
Sean Gilligan 2022-03-07 22:23:42 +01:00 committed by Andreas Schildbach
parent b8c72c996a
commit da9c12312f
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/test/java/org/bitcoinj/core/BitcoindComparisonTool.java
View File

@ -19,7 +19,6 @@ package org.bitcoinj.core;
import com.google.common.base.*;
import com.google.common.collect.*;
import com.google.common.util.concurrent.SettableFuture;
import org.bitcoinj.core.listeners.*;
import org.bitcoinj.net.*;
import org.bitcoinj.params.*;
@ -30,6 +29,7 @@ import org.slf4j.*;
import java.io.*;
import java.net.*;
import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.atomic.*;
/**
@ -86,7 +86,7 @@ public class BitcoindComparisonTool {
final Set<Sha256Hash> blocksRequested = Collections.synchronizedSet(new HashSet<Sha256Hash>());
final Set<Sha256Hash> blocksPendingSend = Collections.synchronizedSet(new HashSet<Sha256Hash>());
final AtomicInteger unexpectedInvs = new AtomicInteger(0);
final SettableFuture<Void> connectedFuture = SettableFuture.create();
final CompletableFuture<Void> connectedFuture = new CompletableFuture<>();
bitcoind.addConnectedEventListener(Threading.SAME_THREAD, (peer, peerCount) -> {
if (!peer.getPeerVersionMessage().subVer.contains("Satoshi")) {
System.out.println();
@ -103,7 +103,7 @@ public class BitcoindComparisonTool {
// Make sure bitcoind has no blocks
bitcoind.setDownloadParameters(0, false);
bitcoind.startBlockChainDownload();
connectedFuture.set(null);
connectedFuture.complete(null);
});
bitcoind.addDisconnectedEventListener(Threading.SAME_THREAD, (peer, peerCount) -> {