Add Map::into_inner()

Add a method to convert back into the source stream.
danieldg · Dec 2, 2022 · 2d9655e · 2d9655e
1 parent 047e113
commit 2d9655e
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/adapters.rs b/src/adapters.rs
@@ -560,6 +560,13 @@ pin_project_lite::pin_project! {
     }
 }
 
+impl<S, F> Map<S, F> {
+    /// Convert to source stream.
+    pub fn into_inner(self) -> S {
+        self.stream
+    }
+}
+
 impl<S, F, R> OrderedStream for Map<S, F>
 where
     S: OrderedStream,