Aug 21, 2024 · Aug 20, 2024 · Aug 20, 2024
diff --git a/Cargo.toml b/Cargo.toml
 async-process = { version = "2.0.0", optional = true }

 [target.'cfg(target_arch = "wasm32")'.dependencies]
 gloo-timers = { version = "0.2.1", features = ["futures"], optional = true }
 gloo-timers = { version = "0.3.0", features = ["futures"], optional = true }
 wasm-bindgen-futures = { version = "0.4.10", optional = true }
 futures-channel = { version = "0.3.4", optional = true }

diff --git a/examples/a-chat/server.rs b/examples/a-chat/server.rs
 None =>break,
 },
            void = shutdown.next().fuse() =>match void{
                #[allow(unreachable_patterns)]
 Some(void) =>match void{},
 None =>break,
 }
diff --git a/src/future/future/mod.rs b/src/future/future/mod.rs

    [`Future`]: ../future/trait.Future.html
 "#]
 #[cfg(any(feature ="std", feature ="docs"))]
 pubtraitFutureExt:Future{
 /// Returns a Future that delays execution for a specified time.
 ///
 }
 }

 #[cfg(any(feature ="std", feature ="docs"))]
 impl<T:Future + ?Sized>FutureExtforT{}

diff --git a/src/io/buf_writer.rs b/src/io/buf_writer.rs
 /// # Ok(()) }) }
 ///```
 #[derive(Debug)]
 pubstructIntoInnerError<W>(W,crate::io::Error);
 pubstructIntoInnerError<W>(W,#[allow(dead_code)]crate::io::Error);

 impl<W:Write>BufWriter<W>{
 /// Creates a new `BufWriter` with a default buffer capacity. The default is currently 8 KB,
diff --git a/src/io/read/bytes.rs b/src/io/read/bytes.rs
    }
 }

 #[cfg(all(test, default))]
 #[cfg(all(test,feature = "default", not(target_arch = "wasm32")))]
 mod tests {
    use crate::io;
    use crate::prelude::*;
diff --git a/src/io/read/chain.rs b/src/io/read/chain.rs
    }
 }

 #[cfg(all(test, default))]
 #[cfg(all(test,feature = "default", not(target_arch = "wasm32")))]
 mod tests {
    use crate::io;
    use crate::prelude::*;
diff --git a/src/io/stderr.rs b/src/io/stderr.rs
    }

    cfg_io_safety! {
        use crate::os::unix::io::{AsHandle, BorrowedHandle};
        use crate::os::windows::io::{AsHandle, BorrowedHandle};

        impl AsHandle for Stderr {
            fn as_handle(&self) -> BorrowedHandle<'_> {
                std::io::stderr().as_handle()
                unsafe {
                    BorrowedHandle::borrow_raw(std::io::stderr().as_raw_handle())
                }
            }
        }
    }
diff --git a/src/io/stdin.rs b/src/io/stdin.rs
    }

    cfg_io_safety! {
        use crate::os::unix::io::{AsFd, BorrowedFd};
        use crate::os::windows::io::{AsHandle, BorrowedHandle};

        impl AsFd for Stdin {
            fn as_fd(&self) -> BorrowedFd<'_> {
                std::io::stdin().as_fd()
        impl AsHandle for Stdin {
            fn as_handle(&self) -> BorrowedHandle<'_> {
                unsafe {
                    BorrowedHandle::borrow_raw(std::io::stdin().as_raw_handle())
                }
            }
        }
    }
diff --git a/src/io/stdout.rs b/src/io/stdout.rs
    }

    cfg_io_safety! {
        use crate::os::unix::io::{AsHandle, BorrowedHandle};
        use crate::os::windows::io::{AsHandle, BorrowedHandle};

        impl AsHandle for Stdout {
            fn as_handle(&self) -> BorrowedHandle<'_> {
                std::io::stdout().as_handle()
                unsafe {
                    BorrowedHandle::borrow_raw(std::io::stdout().as_raw_handle())
                }
            }
        }
    }
diff --git a/src/lib.rs b/src/lib.rs
 #![doc(test(attr(allow(unused_extern_crates, unused_variables))))]
 #![doc(html_logo_url ="https://async.rs/images/logo--hero.svg")]

 externcrate alloc;

 #[macro_use]
 mod utils;

diff --git a/src/net/tcp/stream.rs b/src/net/tcp/stream.rs

        impl From<OwnedSocket> for TcpStream {
            fn from(fd: OwnedSocket) -> TcpStream {
                std::net::TcpListener::from(fd).into()
                std::net::TcpStream::from(fd).into()
            }
        }

        impl From<TcpStream> for OwnedSocket {
            fn from(stream: TcpStream) -> OwnedSocket {
                stream.watcher.into_inner().unwrap().into()
                stream.watcher.get_ref().try_clone().unwrap().into()
            }
        }
    }
diff --git a/src/net/udp/mod.rs b/src/net/udp/mod.rs

        impl From<OwnedSocket> for UdpSocket {
            fn from(fd: OwnedSocket) -> UdpSocket {
                std::net::TcpListener::from(fd).into()
                std::net::UdpSocket::from(fd).into()
            }
        }

diff --git a/src/stream/mod.rs b/src/stream/mod.rs
 //! [`Stream`] looks like this:
 //!
 //! ```
 //! #![allow(dead_code)]
 //! # use async_std::task::{Context, Poll};
 //! # use std::pin::Pin;
 //! trait Stream {
 //!pubtrait Stream {
 //!     type Item;
 //!     fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>;
 //! }
 //! # impl Stream for () {
 //! #   type Item = ();
 //! #   fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { Poll::Pending }
 //! # }
 //! ```
 //!
 //! A stream has a method, [`next`], which when called, returns an
diff --git a/src/utils.rs b/src/utils.rs
 use alloc::string::String;

 /// Calls a function and aborts if it panics.
 ///
 /// This is useful in unsafe code where we can't recover from panics.
 }

 /// Add additional context to errors
 #[cfg(feature ="std")]
 pub(crate)traitContext{
 fncontext(self,message:implFn() ->String) ->Self;
 }
 ($($item:item)*) =>{
        $(
            #[cfg(all(feature ="default", feature ="unstable"))]
            #[cfg_attr(feature ="docs", doc(unstable))]
            #[cfg_attr(feature ="docs", doc(cfg(unstable)))]
            $item
 )*
 }
 ($($item:item)*) =>{
        $(
            #[cfg(any(unix, feature ="docs"))]
            #[cfg_attr(feature ="docs", doc(cfg(unix)))]
            $item
 )*
 }
 ($($item:item)*) =>{
        $(
            #[cfg(any(windows, feature ="docs"))]
            #[cfg_attr(feature ="docs", doc(cfg(windows)))]
            $item
 )*
 }
Original file line number	Diff line number	Diff line change
Expand Up		@@ -86,7 +86,7 @@ futures-lite = { version = "2.0.0", optional = true }
		async-process = { version = "2.0.0", optional = true }

		[target.'cfg(target_arch = "wasm32")'.dependencies]
		gloo-timers = { version = "0.2.1", features = ["futures"], optional = true }
		gloo-timers = { version = "0.3.0", features = ["futures"], optional = true }
		wasm-bindgen-futures = { version = "0.4.10", optional = true }
		futures-channel = { version = "0.3.4", optional = true }

Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -96,6 +96,7 @@ async fn connection_writer_loop(
		None =>break,
		},
		void = shutdown.next().fuse() =>match void{
		#[allow(unreachable_patterns)]
		Some(void) =>match void{},
		None =>break,
		}
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -27,6 +27,7 @@ pub use core::future::Future as Future;

		[`Future`]: ../future/trait.Future.html
		"#]
		#[cfg(any(feature ="std", feature ="docs"))]
		pubtraitFutureExt:Future{
		/// Returns a Future that delays execution for a specified time.
		///
Expand DownExpand Up		@@ -284,5 +285,6 @@ pub trait FutureExt: Future {
		}
		}

		#[cfg(any(feature ="std", feature ="docs"))]
		impl<T:Future + ?Sized>FutureExtforT{}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -114,7 +114,7 @@ pin_project! {
		/// # Ok(()) }) }
		///```
		#[derive(Debug)]
		pubstructIntoInnerError<W>(W,crate::io::Error);
		pubstructIntoInnerError<W>(W,#[allow(dead_code)]crate::io::Error);

		impl<W:Write>BufWriter<W>{
		/// Creates a new `BufWriter` with a default buffer capacity. The default is currently 8 KB,
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -32,7 +32,7 @@ impl<T: Read + Unpin> Stream for Bytes<T> {
		}
		}

		#[cfg(all(test, default))]
		#[cfg(all(test,feature = "default", not(target_arch = "wasm32")))]
		mod tests {
		use crate::io;
		use crate::prelude::*;
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -165,7 +165,7 @@ impl<T: BufRead, U: BufRead> BufRead for Chain<T, U> {
		}
		}

		#[cfg(all(test, default))]
		#[cfg(all(test,feature = "default", not(target_arch = "wasm32")))]
		mod tests {
		use crate::io;
		use crate::prelude::*;
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -204,11 +204,13 @@ cfg_windows! {
		}

		cfg_io_safety! {
		use crate::os::unix::io::{AsHandle, BorrowedHandle};
		use crate::os::windows::io::{AsHandle, BorrowedHandle};

		impl AsHandle for Stderr {
		fn as_handle(&self) -> BorrowedHandle<'_> {
		std::io::stderr().as_handle()
		unsafe {
		BorrowedHandle::borrow_raw(std::io::stderr().as_raw_handle())
		}
		}
		}
		}
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -230,11 +230,13 @@ cfg_windows! {
		}

		cfg_io_safety! {
		use crate::os::unix::io::{AsFd, BorrowedFd};
		use crate::os::windows::io::{AsHandle, BorrowedHandle};

		impl AsFd for Stdin {
		fn as_fd(&self) -> BorrowedFd<'_> {
		std::io::stdin().as_fd()
		impl AsHandle for Stdin {
		fn as_handle(&self) -> BorrowedHandle<'_> {
		unsafe {
		BorrowedHandle::borrow_raw(std::io::stdin().as_raw_handle())
		}
		}
		}
		}
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -284,8 +284,6 @@
		#![doc(test(attr(allow(unused_extern_crates, unused_variables))))]
		#![doc(html_logo_url ="https://async.rs/images/logo--hero.svg")]

		externcrate alloc;

		#[macro_use]
		mod utils;

Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -477,13 +477,13 @@ cfg_windows! {

		impl From<OwnedSocket> for TcpStream {
		fn from(fd: OwnedSocket) -> TcpStream {
		std::net::TcpListener::from(fd).into()
		std::net::TcpStream::from(fd).into()
		}
		}

		impl From<TcpStream> for OwnedSocket {
		fn from(stream: TcpStream) -> OwnedSocket {
		stream.watcher.into_inner().unwrap().into()
		stream.watcher.get_ref().try_clone().unwrap().into()
		}
		}
		}
Expand Down