tests pass

Author: rklaehn

examples/random_store.rs

@@ -6,7 +6,7 @@ use iroh::{SecretKey, Watcher};
 use iroh_base::ticket::NodeTicket;
 use iroh_blobs::{
     api::downloader::Shuffled,
-    provider::{AbortReason, Event, EventMask, EventSender2, ProviderMessage},
+    provider::{AbortReason, EventMask, EventSender2, ProviderMessage},
     store::fs::FsStore,
     test::{add_hash_sequences, create_random_blobs},
     HashAndFormat,
@@ -100,12 +100,7 @@ pub fn get_or_generate_secret_key() -> Result<SecretKey> {
     }
 }
 
-pub fn dump_provider_events(
-    allow_push: bool,
-) -> (
-    tokio::task::JoinHandle<()>,
-    EventSender2,
-) {
+pub fn dump_provider_events(allow_push: bool) -> (tokio::task::JoinHandle<()>, EventSender2) {
     let (tx, mut rx) = mpsc::channel(100);
     let dump_task = tokio::spawn(async move {
         while let Some(event) = rx.recv().await {

src/api/blobs.rs

@@ -57,7 +57,7 @@ use super::{
 };
 use crate::{
     api::proto::{BatchRequest, ImportByteStreamUpdate},
-    provider::{ReaderContext, WriterContext},
+    provider::WriterContext,
     store::IROH_BLOCK_SIZE,
     util::temp_tag::TempTag,
     BlobFormat, Hash, HashAndFormat,
@@ -1180,9 +1180,6 @@ impl WriteProgress for WriterContext {
     }
 
     async fn send_transfer_started(&mut self, index: u64, hash: &Hash, size: u64) {
-        self.tracker
-            .transfer_started(index, hash, size)
-            .await 
-            .ok();
+        self.tracker.transfer_started(index, hash, size).await.ok();
     }
 }

src/net_protocol.rs

@@ -43,15 +43,9 @@ use iroh::{
     protocol::{AcceptError, ProtocolHandler},
     Endpoint, Watcher,
 };
-use tokio::sync::mpsc;
 use tracing::error;
 
-use crate::{
-    api::Store,
-    provider::{Event, EventSender2},
-    ticket::BlobTicket,
-    HashAndFormat,
-};
+use crate::{api::Store, provider::EventSender2, ticket::BlobTicket, HashAndFormat};
 
 #[derive(Debug)]
 pub(crate) struct BlobsInner {