mirror of
https://github.com/async-rs/async-std.git
synced 2025-01-30 17:25:32 +00:00
silence warnings reported by newer rust versions
This commit is contained in:
parent
79c89d779d
commit
57eafb41d0
13 changed files with 27 additions and 22 deletions
|
@ -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,
|
||||
}
|
||||
|
|
|
@ -27,6 +27,7 @@ pub use core::future::Future as Future;
|
|||
|
||||
[`Future`]: ../future/trait.Future.html
|
||||
"#]
|
||||
#[cfg(any(feature = "std", feature = "docs"))]
|
||||
pub trait FutureExt: Future {
|
||||
/// Returns a Future that delays execution for a specified time.
|
||||
///
|
||||
|
@ -284,5 +285,6 @@ pub trait FutureExt: Future {
|
|||
}
|
||||
}
|
||||
|
||||
#[cfg(any(feature = "std", feature = "docs"))]
|
||||
impl<T: Future + ?Sized> FutureExt for T {}
|
||||
|
||||
|
|
|
@ -114,7 +114,7 @@ pin_project! {
|
|||
/// # Ok(()) }) }
|
||||
///```
|
||||
#[derive(Debug)]
|
||||
pub struct IntoInnerError<W>(W, crate::io::Error);
|
||||
pub struct IntoInnerError<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,
|
||||
|
|
|
@ -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::*;
|
||||
|
|
|
@ -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::*;
|
||||
|
|
|
@ -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())
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -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())
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -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 Stdout {
|
||||
fn as_handle(&self) -> BorrowedHandle<'_> {
|
||||
std::io::stdout().as_handle()
|
||||
unsafe {
|
||||
BorrowedHandle::borrow_raw(std::io::stdout().as_raw_handle())
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -284,8 +284,6 @@
|
|||
#![doc(test(attr(allow(unused_extern_crates, unused_variables))))]
|
||||
#![doc(html_logo_url = "https://async.rs/images/logo--hero.svg")]
|
||||
|
||||
extern crate alloc;
|
||||
|
||||
#[macro_use]
|
||||
mod utils;
|
||||
|
||||
|
|
|
@ -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()
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -620,7 +620,7 @@ cfg_windows! {
|
|||
|
||||
impl From<OwnedSocket> for UdpSocket {
|
||||
fn from(fd: OwnedSocket) -> UdpSocket {
|
||||
std::net::TcpListener::from(fd).into()
|
||||
std::net::UdpSocket::from(fd).into()
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
@ -34,9 +34,10 @@
|
|||
//! [`Stream`] looks like this:
|
||||
//!
|
||||
//! ```
|
||||
//! #![allow(dead_code)]
|
||||
//! # use async_std::task::{Context, Poll};
|
||||
//! # use std::pin::Pin;
|
||||
//! trait Stream {
|
||||
//! pub trait Stream {
|
||||
//! type Item;
|
||||
//! fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>;
|
||||
//! }
|
||||
|
|
|
@ -1,5 +1,3 @@
|
|||
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.
|
||||
|
@ -55,6 +53,7 @@ pub fn random(n: u32) -> u32 {
|
|||
}
|
||||
|
||||
/// Add additional context to errors
|
||||
#[cfg(feature = "std")]
|
||||
pub(crate) trait Context {
|
||||
fn context(self, message: impl Fn() -> String) -> Self;
|
||||
}
|
||||
|
@ -148,7 +147,7 @@ macro_rules! cfg_unstable_default {
|
|||
($($item:item)*) => {
|
||||
$(
|
||||
#[cfg(all(feature = "default", feature = "unstable"))]
|
||||
#[cfg_attr(feature = "docs", doc(unstable))]
|
||||
#[cfg_attr(feature = "docs", doc(cfg(unstable)))]
|
||||
$item
|
||||
)*
|
||||
}
|
||||
|
@ -161,7 +160,6 @@ macro_rules! cfg_unix {
|
|||
($($item:item)*) => {
|
||||
$(
|
||||
#[cfg(any(unix, feature = "docs"))]
|
||||
#[cfg_attr(feature = "docs", doc(cfg(unix)))]
|
||||
$item
|
||||
)*
|
||||
}
|
||||
|
@ -174,7 +172,6 @@ macro_rules! cfg_windows {
|
|||
($($item:item)*) => {
|
||||
$(
|
||||
#[cfg(any(windows, feature = "docs"))]
|
||||
#[cfg_attr(feature = "docs", doc(cfg(windows)))]
|
||||
$item
|
||||
)*
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue