Fix clippy warnings

lib/src/network/client.rs

@@ -111,7 +111,7 @@ impl Client {
                 branches_to_reload = reload_index_rx.changed() => {
                     if let Ok(branches_to_reload) = branches_to_reload {
                         for branch_to_reload in &branches_to_reload {
-                            self.reload_index(&branch_to_reload);
+                            self.reload_index(branch_to_reload);
                         }
                     }
                 }

lib/src/network/tests.rs

@@ -148,7 +148,7 @@ async fn transfer_blocks_between_two_replicas_case(block_count: usize, rng_seed:
         }
 
         // Then wait until replica B receives and writes it too.
-        for (id, _block) in snapshot.blocks() {
+        for id in snapshot.blocks().keys() {
             wait_until_block_exists(&b_vault, id).await;
         }
     };

lib/src/sync.rs

@@ -233,9 +233,11 @@ pub(crate) mod broadcast_hash_set {
         }
     }
 
+    type ReceiverState<T> = (uninitialized_watch::Sender<()>, HashSet<T>);
+
     struct Shared<T> {
         id_generator: AtomicUsize,
-        receivers: Mutex<HashMap<usize, (uninitialized_watch::Sender<()>, HashSet<T>)>>,
+        receivers: Mutex<HashMap<usize, ReceiverState<T>>>,
     }
 
     pub fn channel<T>() -> (Sender<T>, Receiver<T>) {
@@ -358,7 +360,7 @@ pub(crate) mod stream {
             loop {
                 match this.inner.as_mut().poll_next(cx) {
                     Poll::Ready(Some(item)) => {
-                        let is_ready = Self::is_ready(&this.ready, &item);
+                        let is_ready = Self::is_ready(this.ready, &item);
 
                         match this.delays.entry(item.clone()) {
                             hash_map::Entry::Occupied(mut entry) => {

lib/tests/sync.rs

@@ -987,7 +987,7 @@ fn redownload_expired_blocks() {
     let test_content = Arc::new(common::random_content(2 * 1024 * 1024));
 
     async fn wait_for_block_count(repo: &Repository, block_count: u64) {
-        common::eventually(&repo, || {
+        common::eventually(repo, || {
             async { repo.count_blocks().await.unwrap() == block_count }
                 .instrument(tracing::Span::current())
         })