ci: unfreeze wasm tests from rustc 1.88.0

.github/workflows/ci.yml

@@ -1055,10 +1055,10 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v5
-      - name: Install Rust 1.88.0
+      - name: Install Rust ${{ env.rust_stable }}
         uses: dtolnay/rust-toolchain@stable
         with:
-          toolchain: 1.88.0
+          toolchain: ${{ env.rust_stable }}
       - name: Install wasm-pack
         uses: taiki-e/install-action@wasm-pack
 
@@ -1078,10 +1078,10 @@ jobs:
           - wasm32-wasip1-threads
     steps:
       - uses: actions/checkout@v4
-      - name: Install Rust 1.88.0
+      - name: Install Rust ${{ env.rust_stable }}
         uses: dtolnay/rust-toolchain@stable
         with:
-          toolchain: 1.88.0
+          toolchain: ${{ env.rust_stable }}
           targets: ${{ matrix.target }}
 
       # Install dependencies
@@ -1092,11 +1092,14 @@ jobs:
 
       - uses: Swatinem/rust-cache@v2
       - name: WASI test tokio full
-        run: cargo test -p tokio --target ${{ matrix.target }} --features full
+        run: cargo test -p tokio --target ${{ matrix.target }} --features "sync,macros,io-util,rt,time"
         env:
           CARGO_TARGET_WASM32_WASIP1_RUNNER: "wasmtime run --"
           CARGO_TARGET_WASM32_WASIP1_THREADS_RUNNER: "wasmtime run -W bulk-memory=y -W threads=y -S threads=y --"
           RUSTFLAGS: --cfg tokio_unstable -Dwarnings -C target-feature=+atomics,+bulk-memory -C link-args=--max-memory=67108864
+          # in order to run doctests for unstable features, we must also pass
+          # the unstable cfg to RustDoc
+          RUSTDOCFLAGS: --cfg tokio_unstable
 
       - name: WASI test tokio-util full
         run: cargo test -p tokio-util --target ${{ matrix.target }} --features full

tokio-stream/src/empty.rs

@@ -26,7 +26,10 @@ unsafe impl<T> Sync for Empty<T> {}
 /// ```
 /// use tokio_stream::{self as stream, StreamExt};
 ///
+/// # /*
 /// #[tokio::main]
+/// # */
+/// # #[tokio::main(flavor = "current_thread")]
 /// async fn main() {
 ///     let mut none = stream::empty::<i32>();
 ///

tokio-stream/src/lib.rs

@@ -34,7 +34,10 @@
 //! ```rust
 //! use tokio_stream::{self as stream, StreamExt};
 //!
+//! # /*
 //! #[tokio::main]
+//! # */
+//! # #[tokio::main(flavor = "current_thread")]
 //! async fn main() {
 //!     let mut stream = stream::iter(vec![0, 1, 2]);
 //!

tokio-stream/src/once.rs

@@ -22,7 +22,10 @@ impl<I> Unpin for Once<I> {}
 /// ```
 /// use tokio_stream::{self as stream, StreamExt};
 ///
+/// # /*
 /// #[tokio::main]
+/// # */
+/// # #[tokio::main(flavor = "current_thread")]
 /// async fn main() {
 ///     // one is the loneliest number
 ///     let mut one = stream::once(1);

tokio-stream/src/stream_close.rs

@@ -17,7 +17,10 @@ pin_project! {
     /// ```
     /// use tokio_stream::{StreamExt, StreamMap, StreamNotifyClose};
     ///
+    /// # /*
     /// #[tokio::main]
+    /// # */
+    /// # #[tokio::main(flavor = "current_thread")]
     /// async fn main() {
     ///     let mut map = StreamMap::new();
     ///     let stream = StreamNotifyClose::new(tokio_stream::iter(vec![0, 1]));

tokio-stream/src/stream_ext.rs

@@ -129,7 +129,7 @@ pub trait StreamExt: Stream {
     /// # Examples
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -171,8 +171,9 @@ pub trait StreamExt: Stream {
     /// # Examples
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
+    ///
     /// use tokio_stream::{self as stream, StreamExt};
     ///
     /// let mut stream = stream::iter(vec![Ok(1), Ok(2), Err("nope")]);
@@ -203,7 +204,7 @@ pub trait StreamExt: Stream {
     /// # Examples
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -239,7 +240,7 @@ pub trait StreamExt: Stream {
     /// # Examples
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -283,7 +284,7 @@ pub trait StreamExt: Stream {
     /// # Examples
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -418,7 +419,7 @@ pub trait StreamExt: Stream {
     /// # Examples
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -454,7 +455,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -514,7 +515,10 @@ pub trait StreamExt: Stream {
     ///     }
     /// }
     ///
+    /// # /*
     /// #[tokio::main]
+    /// # */
+    /// # #[tokio::main(flavor = "current_thread")]
     /// async fn main() {
     ///     let mut stream = Alternate { state: 0 };
     ///
@@ -551,7 +555,7 @@ pub trait StreamExt: Stream {
     /// # Examples
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -580,7 +584,7 @@ pub trait StreamExt: Stream {
     /// # Examples
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -606,7 +610,7 @@ pub trait StreamExt: Stream {
     /// # Examples
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -637,7 +641,7 @@ pub trait StreamExt: Stream {
     /// # Examples
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     /// let mut stream = stream::iter(vec![1,2,3,4,1]).skip_while(|x| *x < 3);
@@ -680,7 +684,7 @@ pub trait StreamExt: Stream {
     /// Basic usage:
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -695,7 +699,7 @@ pub trait StreamExt: Stream {
     /// Stopping at the first `false`:
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -739,7 +743,7 @@ pub trait StreamExt: Stream {
     /// Basic usage:
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -754,7 +758,7 @@ pub trait StreamExt: Stream {
     /// Stopping at the first `true`:
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     ///
@@ -787,7 +791,10 @@ pub trait StreamExt: Stream {
     /// ```
     /// use tokio_stream::{self as stream, StreamExt};
     ///
+    /// # /*
     /// #[tokio::main]
+    /// # */
+    /// # #[tokio::main(flavor = "current_thread")]
     /// async fn main() {
     ///     let one = stream::iter(vec![1, 2, 3]);
     ///     let two = stream::iter(vec![4, 5, 6]);
@@ -823,7 +830,7 @@ pub trait StreamExt: Stream {
     /// # Examples
     /// Basic usage:
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, *};
     ///
@@ -874,7 +881,10 @@ pub trait StreamExt: Stream {
     /// ```
     /// use tokio_stream::{self as stream, StreamExt};
     ///
+    /// # /*
     /// #[tokio::main]
+    /// # */
+    /// # #[tokio::main(flavor = "current_thread")]
     /// async fn main() {
     ///     let doubled: Vec<i32> =
     ///         stream::iter(vec![1, 2, 3])
@@ -891,7 +901,10 @@ pub trait StreamExt: Stream {
     /// ```
     /// use tokio_stream::{self as stream, StreamExt};
     ///
+    /// # /*
     /// #[tokio::main]
+    /// # */
+    /// # #[tokio::main(flavor = "current_thread")]
     /// async fn main() {
     ///     // A stream containing only `Ok` values will be collected
     ///     let values: Result<Vec<i32>, &str> =
@@ -945,7 +958,7 @@ pub trait StreamExt: Stream {
     /// Suppose we have a stream `int_stream` that yields 3 numbers (1, 2, 3):
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     /// use std::time::Duration;
@@ -1031,7 +1044,7 @@ pub trait StreamExt: Stream {
     /// Suppose we have a stream `int_stream` that yields 3 numbers (1, 2, 3):
     ///
     /// ```
-    /// # #[tokio::main]
+    /// # #[tokio::main(flavor = "current_thread")]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
     /// use std::time::Duration;

tokio-stream/src/stream_map.rs

@@ -65,7 +65,10 @@ use std::task::{ready, Context, Poll};
 /// use tokio::sync::mpsc;
 /// use std::pin::Pin;
 ///
+/// # /*
 /// #[tokio::main]
+/// # */
+/// # #[tokio::main(flavor = "current_thread")]
 /// async fn main() {
 ///     let (tx1, mut rx1) = mpsc::channel::<usize>(10);
 ///     let (tx2, mut rx2) = mpsc::channel::<usize>(10);
@@ -185,7 +188,10 @@ use std::task::{ready, Context, Poll};
 /// ```
 /// use tokio_stream::{StreamExt, StreamMap, StreamNotifyClose};
 ///
+/// # /*
 /// #[tokio::main]
+/// # */
+/// # #[tokio::main(flavor = "current_thread")]
 /// async fn main() {
 ///     let mut map = StreamMap::new();
 ///     let stream = StreamNotifyClose::new(tokio_stream::iter(vec![0, 1]));

tokio-stream/src/wrappers/tcp_listener.rs

@@ -10,7 +10,7 @@ use tokio::net::{TcpListener, TcpStream};
 ///
 /// Accept connections from both IPv4 and IPv6 listeners in the same loop:
 ///
-/// ```no_run
+/// ```no_run,ignore-wasm
 /// use std::net::{Ipv4Addr, Ipv6Addr};
 ///
 /// use tokio::net::TcpListener;

tokio-stream/src/wrappers/watch.rs

@@ -17,7 +17,7 @@ use tokio::sync::watch::error::RecvError;
 /// # Examples
 ///
 /// ```
-/// # #[tokio::main]
+/// # #[tokio::main(flavor = "current_thread")]
 /// # async fn main() {
 /// use tokio_stream::{StreamExt, wrappers::WatchStream};
 /// use tokio::sync::watch;
@@ -33,7 +33,7 @@ use tokio::sync::watch::error::RecvError;
 /// ```
 ///
 /// ```
-/// # #[tokio::main]
+/// # #[tokio::main(flavor = "current_thread")]
 /// # async fn main() {
 /// use tokio_stream::{StreamExt, wrappers::WatchStream};
 /// use tokio::sync::watch;
@@ -51,7 +51,7 @@ use tokio::sync::watch::error::RecvError;
 /// Example with [`WatchStream<T>::from_changes`]:
 ///
 /// ```
-/// # #[tokio::main]
+/// # #[tokio::main(flavor = "current_thread")]
 /// # async fn main() {
 /// use futures::future::FutureExt;
 /// use tokio::sync::watch;