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

Wallet: use functional style in method calcBloomOutPointsLocked()

Browse source
This commit is contained in:
Sean Gilligan 2023-08-09 11:45:13 -07:00 • committed by Andreas Schildbach
parent 05c625113f
commit cc88c3a9d4
1 changed files with 11 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
core/src/main/java/org/bitcoinj/wallet/Wallet.java
View file

@ -139,6 +139,8 @@ import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.locks.ReentrantLock;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import static org.bitcoinj.base.internal.Preconditions.checkArgument;
import static org.bitcoinj.base.internal.Preconditions.checkState;
@ -5205,21 +5207,15 @@ public class Wallet extends BaseTaggableObject
private void calcBloomOutPointsLocked() {
// TODO: This could be done once and then kept up to date.
bloomOutPoints.clear();
Set<Transaction> all = new HashSet<>();
all.addAll(unspent.values());
all.addAll(spent.values());
all.addAll(pending.values());
for (Transaction tx : all) {
for (TransactionOutput out : tx.getOutputs()) {
try {
if (isTxOutputBloomFilterable(out))
bloomOutPoints.add(out.getOutPointFor());
} catch (ScriptException e) {
// If it is ours, we parsed the script correctly, so this shouldn't happen.
throw new RuntimeException(e);
}
}
}
// Search unspent, spent, and pending for all TransactionOutputs that are bloom filterable and
// then collect a list of the corresponding TransactionOutPoints.
List<TransactionOutPoint> outPoints = Stream.of(unspent.values(), spent.values(), pending.values())
.flatMap(Collection::stream)
.flatMap(tx -> tx.getOutputs().stream())
.filter(this::isTxOutputBloomFilterable)
.map(TransactionOutput::getOutPointFor)
.collect(Collectors.toList());
bloomOutPoints.addAll(outPoints);
}
@Override @GuardedBy("keyChainGroupLock")