tokio|tokio-stream|tokio-util - ignore failing wasm tests

Author: lblack00

tests-build/tests/fail/macros_type_mismatch.stderr

@@ -57,6 +57,8 @@ error[E0277]: the `?` operator can only be used in an async block that returns `
 39 | async fn question_mark_operator_with_invalid_option() -> Option<()> {
 40 |     None?;
    |         ^ cannot use the `?` operator in an async block that returns `()`
+   |
+   = help: the trait `FromResidual<Option<Infallible>>` is not implemented for `()`
 
 error[E0308]: mismatched types
   --> tests/fail/macros_type_mismatch.rs:40:5
@@ -85,6 +87,8 @@ error[E0277]: the `?` operator can only be used in an async block that returns `
 56 | async fn question_mark_operator_with_invalid_result() -> Result<(), ()> {
 57 |     Ok(())?;
    |           ^ cannot use the `?` operator in an async block that returns `()`
+   |
+   = help: the trait `FromResidual<Result<Infallible, _>>` is not implemented for `()`
 
 error[E0308]: mismatched types
   --> tests/fail/macros_type_mismatch.rs:57:5

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]