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,7 +1092,7 @@ 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 --"

tokio-stream/src/empty.rs

@@ -23,7 +23,7 @@ unsafe impl<T> Sync for Empty<T> {}
 ///
 /// Basic usage:
 ///
-/// ```
+/// ```ignore-wasm
 /// use tokio_stream::{self as stream, StreamExt};
 ///
 /// #[tokio::main]

tokio-stream/src/lib.rs

@@ -31,7 +31,7 @@
 //! `Stream`, but this is unfortunately not possible. Instead, you can use a
 //! `while let` loop as follows:
 //!
-//! ```rust
+//! ```rust,ignore-wasm
 //! use tokio_stream::{self as stream, StreamExt};
 //!
 //! #[tokio::main]

tokio-stream/src/once.rs

@@ -19,7 +19,7 @@ impl<I> Unpin for Once<I> {}
 ///
 /// # Examples
 ///
-/// ```
+/// ```ignore-wasm
 /// use tokio_stream::{self as stream, StreamExt};
 ///
 /// #[tokio::main]

tokio-stream/src/stream_close.rs

@@ -14,7 +14,7 @@ pin_project! {
     ///
     /// Using `StreamNotifyClose` to handle closed streams with `StreamMap`.
     ///
-    /// ```
+    /// ```ignore-wasm
     /// use tokio_stream::{StreamExt, StreamMap, StreamNotifyClose};
     ///
     /// #[tokio::main]

tokio-stream/src/stream_ext.rs

@@ -128,7 +128,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -170,7 +170,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -202,7 +202,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -238,7 +238,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -282,7 +282,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -417,7 +417,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -453,7 +453,7 @@ pub trait StreamExt: Stream {
     /// standard library.
     ///
     /// # Examples
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -487,7 +487,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// use tokio_stream::{Stream, StreamExt};
     ///
     /// use std::pin::Pin;
@@ -550,7 +550,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -579,7 +579,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -605,7 +605,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -636,7 +636,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -679,7 +679,7 @@ pub trait StreamExt: Stream {
     ///
     /// Basic usage:
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -694,7 +694,7 @@ pub trait StreamExt: Stream {
     ///
     /// Stopping at the first `false`:
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -738,7 +738,7 @@ pub trait StreamExt: Stream {
     ///
     /// Basic usage:
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -753,7 +753,7 @@ pub trait StreamExt: Stream {
     ///
     /// Stopping at the first `true`:
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -784,7 +784,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     ///
-    /// ```
+    /// ```ignore-wasm
     /// use tokio_stream::{self as stream, StreamExt};
     ///
     /// #[tokio::main]
@@ -822,7 +822,7 @@ pub trait StreamExt: Stream {
     ///
     /// # Examples
     /// Basic usage:
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, *};
@@ -871,7 +871,7 @@ pub trait StreamExt: Stream {
     ///
     /// Basic usage:
     ///
-    /// ```
+    /// ```ignore-wasm
     /// use tokio_stream::{self as stream, StreamExt};
     ///
     /// #[tokio::main]
@@ -888,7 +888,7 @@ pub trait StreamExt: Stream {
     ///
     /// Collecting a stream of `Result` values
     ///
-    /// ```
+    /// ```ignore-wasm
     /// use tokio_stream::{self as stream, StreamExt};
     ///
     /// #[tokio::main]
@@ -944,7 +944,7 @@ pub trait StreamExt: Stream {
     ///
     /// Suppose we have a stream `int_stream` that yields 3 numbers (1, 2, 3):
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};
@@ -1030,7 +1030,7 @@ pub trait StreamExt: Stream {
     ///
     /// Suppose we have a stream `int_stream` that yields 3 numbers (1, 2, 3):
     ///
-    /// ```
+    /// ```ignore-wasm
     /// # #[tokio::main]
     /// # async fn main() {
     /// use tokio_stream::{self as stream, StreamExt};

tokio-stream/src/stream_map.rs

@@ -60,7 +60,7 @@ use std::task::{ready, Context, Poll};
 ///
 /// Merging two streams, then remove them after receiving the first value
 ///
-/// ```
+/// ```ignore-wasm
 /// use tokio_stream::{StreamExt, StreamMap, Stream};
 /// use tokio::sync::mpsc;
 /// use std::pin::Pin;
@@ -182,7 +182,7 @@ use std::task::{ready, Context, Poll};
 ///
 /// Using `StreamNotifyClose` to handle closed streams with `StreamMap`.
 ///
-/// ```
+/// ```ignore-wasm
 /// use tokio_stream::{StreamExt, StreamMap, StreamNotifyClose};
 ///
 /// #[tokio::main]

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

@@ -16,7 +16,7 @@ use tokio::sync::watch::error::RecvError;
 ///
 /// # Examples
 ///
-/// ```
+/// ```ignore-wasm
 /// # #[tokio::main]
 /// # async fn main() {
 /// use tokio_stream::{StreamExt, wrappers::WatchStream};
@@ -32,7 +32,7 @@ use tokio::sync::watch::error::RecvError;
 /// # }
 /// ```
 ///
-/// ```
+/// ```ignore-wasm
 /// # #[tokio::main]
 /// # async fn main() {
 /// use tokio_stream::{StreamExt, wrappers::WatchStream};
@@ -50,7 +50,7 @@ use tokio::sync::watch::error::RecvError;
 ///
 /// Example with [`WatchStream<T>::from_changes`]:
 ///
-/// ```
+/// ```ignore-wasm
 /// # #[tokio::main]
 /// # async fn main() {
 /// use futures::future::FutureExt;

tokio-util/src/codec/length_delimited.rs

@@ -78,7 +78,7 @@
 //! The following will parse a `u16` length field at offset 0, omitting the
 //! frame head in the yielded `BytesMut`.
 //!
-//! ```
+//! ```ignore-wasm
 //! # use tokio_stream::StreamExt;
 //! # use tokio_util::codec::LengthDelimitedCodec;
 //! # #[tokio::main]
@@ -114,7 +114,7 @@
 //! The following will parse a `u16` length field at offset 0, including the
 //! frame head in the yielded `BytesMut`.
 //!
-//! ```
+//! ```ignore-wasm
 //! # use tokio_stream::StreamExt;
 //! # use tokio_util::codec::LengthDelimitedCodec;
 //! # #[tokio::main]
@@ -151,7 +151,7 @@
 //! frame head in the yielded `BytesMut`. In this case, the length field
 //! **includes** the frame head length.
 //!
-//! ```
+//! ```ignore-wasm
 //! # use tokio_stream::StreamExt;
 //! # use tokio_util::codec::LengthDelimitedCodec;
 //! # #[tokio::main]
@@ -187,7 +187,7 @@
 //! The following will parse a 3 byte length field at offset 0 in a 5 byte
 //! frame head, including the frame head in the yielded `BytesMut`.
 //!
-//! ```
+//! ```ignore-wasm
 //! # use tokio_stream::StreamExt;
 //! # use tokio_util::codec::LengthDelimitedCodec;
 //! # #[tokio::main]
@@ -234,7 +234,7 @@
 //! yielded `BytesMut`, but the trailing 2 bytes of the frame head will be
 //! included.
 //!
-//! ```
+//! ```ignore-wasm
 //! # use tokio_stream::StreamExt;
 //! # use tokio_util::codec::LengthDelimitedCodec;
 //! # #[tokio::main]
@@ -283,7 +283,7 @@
 //! included. In this case, the length field **includes** the frame head
 //! length.
 //!
-//! ```
+//! ```ignore-wasm
 //! # use tokio_stream::StreamExt;
 //! # use tokio_util::codec::LengthDelimitedCodec;
 //! # #[tokio::main]
@@ -326,7 +326,7 @@
 //! The following will parse a 3 byte length field at offset 0 in a 4 byte
 //! frame head, excluding the 4th byte from the yielded `BytesMut`.
 //!
-//! ```
+//! ```ignore-wasm
 //! # use tokio_stream::StreamExt;
 //! # use tokio_util::codec::LengthDelimitedCodec;
 //! # #[tokio::main]