From 859555334d7e4129215b9f084d9f9840fac5ce36 Mon Sep 17 00:00:00 2001
From: Timon Vonk <timonv@gmail.com>
Date: Wed, 11 Sep 2024 14:22:19 +0200
Subject: [PATCH] fix: Implement into_stream_boxed for all loaders

---
 swiftide-integrations/src/fluvio/loader.rs   | 4 ++++
 swiftide-integrations/src/parquet/loader.rs  | 4 ++++
 swiftide-integrations/src/scraping/loader.rs | 4 ++++
 3 files changed, 12 insertions(+)

diff --git a/swiftide-integrations/src/fluvio/loader.rs b/swiftide-integrations/src/fluvio/loader.rs
index 9173d783..579a64de 100644
--- 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
index bc9094ce..6540f157 100644
--- 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
index dd4adeb5..29058e85 100644
--- 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()
+    }
 }