feat(ingestion_stream): implement into for Result<Vec<IngestionNode>>

bosun-ai · Jun 26, 2024 · 926cc0c · 926cc0c
1 parent d285874
commit 926cc0c
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/swiftide/src/ingestion/ingestion_stream.rs b/swiftide/src/ingestion/ingestion_stream.rs
@@ -42,6 +42,15 @@ impl Into<IngestionStream> for Vec<Result<IngestionNode>> {
     }
 }
 
+impl Into<IngestionStream> for Result<Vec<IngestionNode>> {
+    fn into(self) -> IngestionStream {
+        match self {
+            Ok(nodes) => IngestionStream::iter(nodes.into_iter().map(Ok)),
+            Err(err) => IngestionStream::iter(vec![Err(err)]),
+        }
+    }
+}
+
 impl Into<IngestionStream> for Pin<Box<dyn Stream<Item = Result<IngestionNode>> + Send>> {
     fn into(self) -> IngestionStream {
         IngestionStream { inner: self }