introduce bounded blob downloads

1 files changed, 6 insertions, 2 deletions

diff --git a/src/state/host.rs b/src/state/host.rs
index 6506274..f6c460d 100644
--- a/src/state/host.rs
+++ b/src/state/host.rs
@@ -100,11 +100,15 @@ impl Host for AppState {
         }
     }
 
-    fn fetch_content(&self, hash: [u8; 32]) -> impl Future<Output = Result<Vec<u8>>> + Send {
+    fn fetch_content(
+        &self,
+        hash: [u8; 32],
+        size: u64,
+    ) -> impl Future<Output = Result<Vec<u8>>> + Send {
         let state = self.clone();
         async move {
             let peers = state.active_peers_on_local_epoch().await;
-            crate::swarm::blob::fetch_content(&state, hash, peers).await
+            crate::swarm::blob::fetch_content(&state, hash, size, peers).await
         }
     }