mirrors/electrs
1
0
Fork 0
mirror of https://github.com/romanz/electrs.git synced 2025-02-24 06:57:53 +01:00
Code Issues Projects Releases Wiki Activity

Remove unneeded into_iter()

Browse source
This commit is contained in:
Roman Zeyde 2021-07-04 15:08:26 +03:00
parent c754485320
commit 11d703f545
1 changed files with 16 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
src/status.rs
View file

@ -280,27 +280,23 @@ impl Status {
.par_iter()
.flat_map_iter(|outpoint| index.filter_by_spending(*outpoint))
.collect();
self.for_new_blocks(
spending_blockhashes.into_iter(),
daemon,
|blockhash, block| {
let txids: Vec<Txid> = block.txdata.iter().map(|tx| tx.txid()).collect();
for (pos, (tx, txid)) in block.txdata.into_iter().zip(txids.iter()).enumerate() {
let spent_outpoints = filter_inputs(&tx, &outpoints);
if spent_outpoints.is_empty() {
continue;
}
cache.add_tx(*txid, move || tx);
cache.add_proof(blockhash, *txid, || Proof::create(&txids, pos));
result
.entry(blockhash)
.or_default()
.entry((u32::try_from(pos).unwrap(), *txid))
.or_default()
.spent = spent_outpoints;
self.for_new_blocks(spending_blockhashes, daemon, |blockhash, block| {
let txids: Vec<Txid> = block.txdata.iter().map(|tx| tx.txid()).collect();
for (pos, (tx, txid)) in block.txdata.into_iter().zip(txids.iter()).enumerate() {
let spent_outpoints = filter_inputs(&tx, &outpoints);
if spent_outpoints.is_empty() {
continue;
}
},
)?;
cache.add_tx(*txid, move || tx);
cache.add_proof(blockhash, *txid, || Proof::create(&txids, pos));
result
.entry(blockhash)
.or_default()
.entry((u32::try_from(pos).unwrap(), *txid))
.or_default()
.spent = spent_outpoints;
}
})?;
Ok(result
.into_iter()