trim out all of the not immediatelly necessary bits of futures-time

* don't need streams yet - they arent connected to wasi streams
* don't need channels
* don't need park
* don't need relative future

We can add all of these back in later once we are ready.

Author: pchickey

Cargo.toml

@@ -15,7 +15,6 @@ authors = [
 [features]
 
 [dependencies]
-async-channel.workspace = true
 futures-core.workspace = true
 http.workspace = true
 pin-project-lite.workspace = true
@@ -48,7 +47,6 @@ repository = "https://github.com/yoshuawuyts/wstd"
 
 [workspace.dependencies]
 anyhow = "1"
-async-channel = "1.6.1"
 cargo_metadata = "0.18.1"
 futures-core = "0.3.19"
 futures-lite = "1.12.0"

src/future/future_ext.rs

@@ -1,9 +1,5 @@
-use core::future::Future;
-
-use crate::channel::Parker;
-use crate::stream::IntoStream;
-
-use super::{Delay, IntoFuture, Park, Timeout};
+use super::{Delay, Timeout};
+use std::future::{Future, IntoFuture};
 
 /// Extend `Future` with time-based operations.
 pub trait FutureExt: Future {
@@ -75,19 +71,6 @@ pub trait FutureExt: Future {
     {
         Delay::new(self, deadline.into_future())
     }
-    /// 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

@@ -8,30 +8,18 @@
 //! like with `?` we have to be careful to roll back local state if our future
 //! halts there.
 //!
-//! In order to perform a cancellation remotely, you can use the [`channel::bounded`]
-//! function to create a sender/receiver pair. When the sender side of
-//! this pair emits a message, all receivers are trigered. Receivers can be passed to
-//! [`Future::timeout`] or [`Stream::timeout`] to perform a cancellation when
-//! the message is received.
-//!
-//! [`channel::bounded`]: crate::channel::bounded
-//! [`Future::timeout`]: crate::future::FutureExt::timeout
-//! [`Stream::timeout`]: crate::stream::StreamExt::timeout
-//!
 //!
 //! ```no_run
 //! use futures_lite::prelude::*;
 //! use wstd::prelude::*;
-//! use wstd::channel;
 //! use wstd::time::Duration;
 //!
 //! #[wstd::main]
 //! async fn main() {
-//!     let (send, mut recv) = channel::bounded::<()>(1); // create a new send/receive pair
 //!     let mut counter = 0;
 //!     let value = async { "meow" }
 //!         .delay(Duration::from_millis(100))
-//!         .timeout(recv.next()) // time-out if the sender is dropped.
+//!         .timeout(Duration::from_millis(200))
 //!         .await;
 //!
 //!     assert_eq!(value.unwrap(), "meow");
@@ -40,13 +28,8 @@
 
 mod delay;
 mod future_ext;
-mod park;
-mod relative_future;
 mod timeout;
 
 pub use delay::Delay;
 pub use future_ext::FutureExt;
-pub use park::Park;
-pub use relative_future::Timer;
-pub use std::future::IntoFuture;
 pub use timeout::Timeout;

src/future/park.rs

@@ -55,33 +55,14 @@ pub mod iter;
 pub mod net;
 pub mod rand;
 pub mod runtime;
-pub mod stream;
 pub mod task;
 pub mod time;
 
 pub use wstd_macro::attr_macro_main as main;
 
 pub mod prelude {
     pub use crate::future::FutureExt as _;
-    pub use crate::future::Timer as _;
     pub use crate::http::Body as _;
     pub use crate::io::AsyncRead as _;
     pub use crate::io::AsyncWrite as _;
-    pub use crate::stream::IntoStream as _;
-    pub use crate::stream::StreamExt as _;
-    pub use std::future::IntoFuture as _;
-}
-
-/// An async multi-producer multi-consumer channel.
-pub mod channel {
-    /// Suspend or resume execution of a future.
-    #[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord)]
-    pub enum Parker {
-        /// Put the future into a suspended state.
-        Park,
-        /// Put the future into an active state.
-        Unpark,
-    }
-    #[doc(inline)]
-    pub use async_channel::*;
 }