uncomment all of the park related stuff

Author: pchickey

src/future/future_ext.rs

@@ -1,9 +1,9 @@
 use core::future::Future;
 
-//use crate::channel::Parker;
-//use crate::time::stream::IntoStream;
+use crate::channel::Parker;
+use crate::stream::IntoStream;
 
-use super::{Delay, IntoFuture, Timeout};
+use super::{Delay, IntoFuture, Park, Timeout};
 
 /// Extend `Future` with time-based operations.
 pub trait FutureExt: Future {
@@ -77,21 +77,19 @@ pub trait FutureExt: Future {
     {
         Delay::new(self, deadline.into_future())
     }
-    /* FIXME channels
-        /// Suspend or resume execution of a future.
-        ///
-        /// When this method is called the execution of the future will be put into
-        /// a suspended state until the channel returns `Parker::Unpark` or the
-        /// channel's senders are dropped. The underlying future will not be polled
-        /// while the it is paused.
-        fn park<I>(self, interval: I) -> Park<Self, I::IntoStream>
-        where
-            Self: Sized,
-            I: IntoStream<Item = Parker>,
-        {
-            Park::new(self, interval.into_stream())
-        }
-    */
+    /// Suspend or resume execution of a future.
+    ///
+    /// When this method is called the execution of the future will be put into
+    /// a suspended state until the channel returns `Parker::Unpark` or the
+    /// channel's senders are dropped. The underlying future will not be polled
+    /// while the it is paused.
+    fn park<I>(self, interval: I) -> Park<Self, I::IntoStream>
+    where
+        Self: Sized,
+        I: IntoStream<Item = Parker>,
+    {
+        Park::new(self, interval.into_stream())
+    }
 }
 
 impl<T> FutureExt for T where T: Future {}

src/future/mod.rs

@@ -41,13 +41,13 @@
 
 mod delay;
 mod future_ext;
-//mod park;
+mod park;
 mod relative_future;
 mod timeout;
 
 pub use delay::Delay;
 pub use future_ext::FutureExt;
-//pub use park::Park;
+pub use park::Park;
 pub use relative_future::Timer;
 pub use std::future::IntoFuture;
 pub use timeout::Timeout;

src/stream/mod.rs

@@ -5,7 +5,7 @@ mod debounce;
 mod delay;
 mod interval;
 mod into_stream;
-//mod park;
+mod park;
 mod sample;
 mod stream_ext;
 mod throttle;
@@ -16,7 +16,7 @@ pub use debounce::Debounce;
 pub use delay::Delay;
 pub use interval::{interval, Interval};
 pub use into_stream::IntoStream;
-//pub use park::Park;
+pub use park::Park;
 pub use sample::Sample;
 pub use stream_ext::StreamExt;
 pub use throttle::Throttle;

src/stream/stream_ext.rs

@@ -1,10 +1,10 @@
-//use crate::channel::Parker;
+use crate::channel::Parker;
 use crate::future::Timer;
 use std::future::IntoFuture;
 
 use futures_core::Stream;
 
-use super::{Buffer, Debounce, Delay, IntoStream, /*Park,*/ Sample, Throttle, Timeout};
+use super::{Buffer, Debounce, Delay, IntoStream, Park, Sample, Throttle, Timeout};
 
 /// Extend `Stream` with time-based operations.
 pub trait StreamExt: Stream {
@@ -178,21 +178,19 @@ pub trait StreamExt: Stream {
     {
         Delay::new(self, deadline.into_future())
     }
-    /* FIXME
-        /// Suspend or resume execution of a stream.
-        ///
-        /// When this method is called the execution of the stream will be put into
-        /// a suspended state until the channel returns `Parker::Unpark` or the
-        /// channel's senders are dropped. The underlying stream will not be polled
-        /// while the it is paused.
-        fn park<I>(self, interval: I) -> Park<Self, I::IntoStream>
-        where
-            Self: Sized,
-            I: IntoStream<Item = Parker>,
-        {
-            Park::new(self, interval.into_stream())
-        }
-    */
+    /// Suspend or resume execution of a stream.
+    ///
+    /// When this method is called the execution of the stream will be put into
+    /// a suspended state until the channel returns `Parker::Unpark` or the
+    /// channel's senders are dropped. The underlying stream will not be polled
+    /// while the it is paused.
+    fn park<I>(self, interval: I) -> Park<Self, I::IntoStream>
+    where
+        Self: Sized,
+        I: IntoStream<Item = Parker>,
+    {
+        Park::new(self, interval.into_stream())
+    }
     /// Yield an item, then ignore subsequent items for a duration.
     ///
     /// In addition to using a time-based interval, this method can take any