fix: Implement into_stream_boxed for all loaders

bosun-ai · Sep 11, 2024 · 8595553 · 8595553
1 parent 45d8a57
commit 8595553
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 0 deletions.
diff --git a/swiftide-integrations/src/fluvio/loader.rs b/swiftide-integrations/src/fluvio/loader.rs
@@ -38,6 +38,10 @@ impl Loader for Fluvio {
 
         swiftide_stream.boxed().into()
     }
+
+    fn into_stream_boxed(self: Box<Self>) -> IndexingStream {
+        self.into_stream()
+    }
 }
 
 #[cfg(test)]

diff --git a/swiftide-integrations/src/parquet/loader.rs b/swiftide-integrations/src/parquet/loader.rs
@@ -71,6 +71,10 @@ impl Loader for Parquet {
 
         // let mask = ProjectionMask::
     }
+
+    fn into_stream_boxed(self: Box<Self>) -> IndexingStream {
+        self.into_stream()
+    }
 }
 
 #[cfg(test)]

diff --git a/swiftide-integrations/src/scraping/loader.rs b/swiftide-integrations/src/scraping/loader.rs
@@ -76,4 +76,8 @@ impl Loader for ScrapingLoader {
 
         IndexingStream::iter(rx)
     }
+
+    fn into_stream_boxed(self: Box<Self>) -> IndexingStream {
+        self.into_stream()
+    }
 }