From cd862083a5db3d04c4ff2cbbaa3eb96e50f04ccd Mon Sep 17 00:00:00 2001
From: k-nasa <htilcs1115@gmail.com>
Date: Fri, 18 Oct 2019 12:19:38 +0900
Subject: [PATCH] Add Flatten struct

---
 src/stream/stream/flatten.rs | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/src/stream/stream/flatten.rs b/src/stream/stream/flatten.rs
index e922e94..06e9ec2 100644
--- a/src/stream/stream/flatten.rs
+++ b/src/stream/stream/flatten.rs
@@ -39,6 +39,21 @@ where
     }
 }
 
+pub struct Flatten<S: Stream>
+where
+    S::Item: IntoStream,
+{
+    inner: FlattenCompat<S, <S::Item as IntoStream>::IntoStream>,
+}
+
+impl<S: Stream<Item: IntoStream>> Flatten<S> {
+    pin_utils::unsafe_pinned!(inner: FlattenCompat<S, <S::Item as IntoStream>::IntoStream>);
+
+    pub fn new(stream: S) -> Flatten<S> {
+        Flatten { inner: FlattenCompat::new(stream) }
+    }
+}
+
 /// Real logic of both `Flatten` and `FlatMap` which simply delegate to
 /// this type.
 #[derive(Clone, Debug)]