Cuprate/cuprate
Cuprate/cuprate
1
0
Fork 0
mirror of https://github.com/Cuprate/cuprate.git synced 2025-01-09 20:40:01 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

remove test unwrap

Browse source
This commit is contained in:
Boog900 2024-06-13 15:52:02 +01:00
parent 18d4b77070
commit efbe18b242
No known key found for this signature in database
GPG key ID: 42AB1287CB0041C2
1 changed files with 5 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
p2p/cuprate-p2p/src/block_downloader.rs
View file

@ -4,7 +4,7 @@
//! and downloads it. //! and downloads it.
//! //!
//! The block downloader is started by [`download_blocks`]. //! The block downloader is started by [`download_blocks`].
use futures::FutureExt; use futures::{FutureExt, TryFutureExt};
use std::{ use std::{
cmp::{max, min, Ordering, Reverse}, cmp::{max, min, Ordering, Reverse},
collections::{BTreeMap, BinaryHeap, HashSet}, collections::{BTreeMap, BinaryHeap, HashSet},
@ -161,8 +161,8 @@ where
tokio::spawn( tokio::spawn(
block_downloader block_downloader
.run() .run()
.instrument(Span::current()) .inspect_err(|e| tracing::debug!("Error downloading blocks: {e}"))
.map(|res| panic!("{res:?}")), .instrument(Span::current()),
); );
buffer_stream buffer_stream
@ -476,13 +476,12 @@ where
self.block_download_tasks.spawn(async move { self.block_download_tasks.spawn(async move {
( (
block_entry_to_get.start_height, block_entry_to_get.start_height,
Ok(request_batch_from_peer( request_batch_from_peer(
client, client,
block_entry_to_get.ids, block_entry_to_get.ids,
block_entry_to_get.start_height, block_entry_to_get.start_height,
) )
.await .await,
.unwrap()),
) )
}); });