chore: Impl IntoFuture to collect all the blocks

dariusc93 · Sep 29, 2024 · b29b457 · b29b457
1 parent 45781c9
commit b29b457
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/repo/mod.rs b/src/repo/mod.rs
@@ -1106,6 +1106,18 @@ impl Stream for RepoGetBlocks {
     }
 }
 
+impl IntoFuture for RepoGetBlocks {
+    type Output = Result<Vec<Block>, Error>;
+    type IntoFuture = BoxFuture<'static, Self::Output>;
+    fn into_future(self) -> Self::IntoFuture {
+        async move {
+            let col = self.try_collect().await?;
+            Ok(col)
+        }
+        .boxed()
+    }
+}
+
 pub struct RepoPutBlock<'a> {
     repo: Repo,
     block: &'a Block,