chore: doc links

n0-computer · Mar 15, 2024 · 55044d7 · 55044d7
1 parent 248c26a
commit 55044d7
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 14 deletions.
diff --git a/iroh-bytes/src/downloader.rs b/iroh-bytes/src/downloader.rs
@@ -2,7 +2,7 @@
 //!
 //! The [`Downloader`] interacts with four main components to this end.
 //! - [`Dialer`]: Used to queue opening connections to nodes we need to perform downloads.
-//! - [`ProviderMap`]: Where the downloader obtains information about nodes that could be
+//! - `ProviderMap`: Where the downloader obtains information about nodes that could be
 //!   used to perform a download.
 //! - [`Store`]: Where data is stored.
 //!
@@ -36,11 +36,6 @@ use std::{
     time::Duration,
 };
 
-use crate::{
-    get::{db::DownloadProgress, Stats},
-    store::Store,
-    util::progress::{IdGenerator, ProgressSender},
-};
 use futures::{future::LocalBoxFuture, FutureExt, StreamExt};
 use hashlink::LinkedHashSet;
 use iroh_base::hash::{BlobFormat, Hash, HashAndFormat};
@@ -49,13 +44,15 @@ use tokio::{
     sync::{mpsc, oneshot},
     task::JoinSet,
 };
-use tokio_util::{
-    sync::CancellationToken,
-    task::LocalPoolHandle,
-    time::delay_queue::{self, DelayQueue},
-};
+use tokio_util::{sync::CancellationToken, task::LocalPoolHandle, time::delay_queue};
 use tracing::{debug, error_span, trace, warn, Instrument};
 
+use crate::{
+    get::{db::DownloadProgress, Stats},
+    store::Store,
+    util::progress::{IdGenerator, ProgressSender},
+};
+
 mod get;
 mod invariants;
 mod progress;
@@ -443,7 +440,7 @@ struct Service<G: Getter, D: Dialer> {
     /// Active connections
     nodes: HashMap<NodeId, ConnectionInfo<D::Connection>>,
     /// Queue to manage dropping nodes.
-    goodbye_nodes_queue: DelayQueue<NodeId>,
+    goodbye_nodes_queue: delay_queue::DelayQueue<NodeId>,
     /// Queue of pending downloads.
     queue: LinkedHashSet<DownloadKind>,
     /// Information about pending and active requests

diff --git a/iroh-bytes/src/downloader/test/dialer.rs b/iroh-bytes/src/downloader/test/dialer.rs
@@ -19,7 +19,7 @@ struct TestingDialerInner {
     /// Peers that are being dialed.
     dialing: HashSet<NodeId>,
     /// Queue of dials.
-    dial_futs: DelayQueue<NodeId>,
+    dial_futs: delay_queue::DelayQueue<NodeId>,
     /// History of attempted dials.
     dial_history: Vec<NodeId>,
     /// How long does a dial last.
@@ -32,7 +32,7 @@ impl Default for TestingDialerInner {
     fn default() -> Self {
         TestingDialerInner {
             dialing: HashSet::default(),
-            dial_futs: DelayQueue::default(),
+            dial_futs: delay_queue::DelayQueue::default(),
             dial_history: Vec::default(),
             dial_duration: Duration::ZERO,
             dial_outcome: Box::new(|_| true),