FromStream for ()

Author: sunjay

src/lib.rs

@@ -65,6 +65,7 @@ cfg_if! {
         #[cfg_attr(feature = "docs", doc(cfg(unstable)))]
         pub mod pin;
 
+        mod unit;
         mod vec;
         mod result;
         mod option;

src/unit/from_stream.rs

@@ -0,0 +1,16 @@
+use std::pin::Pin;
+
+use crate::prelude::*;
+use crate::stream::{FromStream, IntoStream};
+
+impl FromStream<()> for () {
+    #[inline]
+    fn from_stream<'a, S: IntoStream<Item = ()>>(
+        stream: S,
+    ) -> Pin<Box<dyn core::future::Future<Output = Self> + 'a>>
+    where
+        <S as IntoStream>::IntoStream: 'a,
+    {
+        Box::pin(stream.into_stream().for_each(|_| ()))
+    }
+}

src/unit/mod.rs

@@ -0,0 +1,6 @@
+//! The Rust primitive `()` type, sometimes called "unit" or "nil".
+//!
+//! This module provides types and implementations for working
+//! asynchronously with values of type `()`.
+
+mod from_stream;