Add builder and use it in one example

Author: rklaehn

examples/custom-protocol.rs

@@ -99,7 +99,7 @@ async fn main() -> Result<()> {
         builder.endpoint().clone(),
         local_pool.handle().clone(),
     );
-    let blobs = Arc::new(Blobs::new_with_events(
+    let blobs = Arc::new(Blobs::new(
         store,
         local_pool.handle().clone(),
         Default::default(),

examples/hello-world-fetch.rs

@@ -45,7 +45,7 @@ async fn main() -> Result<()> {
         builder.endpoint().clone(),
         local_pool.handle().clone(),
     );
-    let blobs = Arc::new(Blobs::new_with_events(
+    let blobs = Arc::new(Blobs::new(
         store,
         local_pool.handle().clone(),
         Default::default(),

examples/hello-world-provide.rs

@@ -3,10 +3,8 @@
 //! This is using an in memory database and a random node id.
 //! run this example from the project root:
 //!     $ cargo run --example hello-world-provide
-use std::sync::Arc;
-
 use iroh_base::{node_addr::AddrInfoOptions, ticket::BlobTicket};
-use iroh_blobs::{downloader::Downloader, net_protocol::Blobs, util::local_pool::LocalPool};
+use iroh_blobs::{net_protocol::Blobs, util::local_pool::LocalPool};
 use tracing_subscriber::{prelude::*, EnvFilter};
 
 // set the RUST_LOG env var to one of {debug,info,warn} to see logging info
@@ -26,21 +24,9 @@ async fn main() -> anyhow::Result<()> {
     // create a new node
     let mut builder = iroh::node::Node::memory().build().await?;
     let local_pool = LocalPool::default();
-    let store = iroh_blobs::store::mem::Store::new();
-    let downloader = Downloader::new(
-        store.clone(),
-        builder.endpoint().clone(),
-        local_pool.handle().clone(),
-    );
-    let blobs = Arc::new(Blobs::new_with_events(
-        store,
-        local_pool.handle().clone(),
-        Default::default(),
-        downloader,
-        builder.endpoint().clone(),
-    ));
-    let blobs_client = blobs.clone().client();
-    builder = builder.accept(iroh_blobs::protocol::ALPN.to_vec(), blobs);
+    let blobs = Blobs::memory().build(local_pool.handle(), builder.endpoint());
+    builder = builder.accept(iroh_blobs::ALPN.to_vec(), blobs.clone());
+    let blobs_client = blobs.client();
     let node = builder.spawn().await?;
 
     // add some data and remember the hash

examples/local-swarm-discovery.rs

@@ -82,7 +82,7 @@ async fn main() -> anyhow::Result<()> {
         builder.endpoint().clone(),
         local_pool.handle().clone(),
     );
-    let blobs = Arc::new(Blobs::new_with_events(
+    let blobs = Arc::new(Blobs::new(
         store,
         local_pool.handle().clone(),
         Default::default(),

src/rpc/client/blobs.rs

@@ -1069,7 +1069,7 @@ mod tests {
                 // Setup blobs
                 let downloader =
                     Downloader::new(store.clone(), endpoint.clone(), local_pool.handle().clone());
-                let blobs = Arc::new(Blobs::new_with_events(
+                let blobs = Arc::new(Blobs::new(
                     store.clone(),
                     local_pool.handle().clone(),
                     events,