#![warn(rust_2018_idioms)] #![cfg(feature = "full")] #![allow(clippy::type_complexity, clippy::diverging_sub_expression)] use std::cell::Cell; use std::future::Future; use std::io::SeekFrom; use std::net::SocketAddr; use std::pin::Pin; use std::rc::Rc; use tokio::net::TcpStream; use tokio::time::{Duration, Instant}; // The names of these structs behaves better when sorted. // Send: Yes, Sync: Yes #[derive(Clone)] struct YY {} // Send: Yes, Sync: No #[derive(Clone)] struct YN { _value: Cell, } // Send: No, Sync: No #[derive(Clone)] struct NN { _value: Rc, } #[allow(dead_code)] type BoxFutureSync = std::pin::Pin + Send + Sync>>; #[allow(dead_code)] type BoxFutureSend = std::pin::Pin + Send>>; #[allow(dead_code)] type BoxFuture = std::pin::Pin>>; #[allow(dead_code)] type BoxAsyncRead = std::pin::Pin>; #[allow(dead_code)] type BoxAsyncSeek = std::pin::Pin>; #[allow(dead_code)] type BoxAsyncWrite = std::pin::Pin>; #[allow(dead_code)] fn require_send(_t: &T) {} #[allow(dead_code)] fn require_sync(_t: &T) {} #[allow(dead_code)] fn require_unpin(_t: &T) {} #[allow(dead_code)] struct Invalid; trait AmbiguousIfSend { fn some_item(&self) {} } impl AmbiguousIfSend<()> for T {} impl AmbiguousIfSend for T {} trait AmbiguousIfSync { fn some_item(&self) {} } impl AmbiguousIfSync<()> for T {} impl AmbiguousIfSync for T {} trait AmbiguousIfUnpin { fn some_item(&self) {} } impl AmbiguousIfUnpin<()> for T {} impl AmbiguousIfUnpin for T {} macro_rules! into_todo { ($typ:ty) => {{ let x: $typ = todo!(); x }}; } macro_rules! async_assert_fn_send { (Send & $(!)?Sync & $(!)?Unpin, $value:expr) => { require_send(&$value); }; (!Send & $(!)?Sync & $(!)?Unpin, $value:expr) => { AmbiguousIfSend::some_item(&$value); }; } macro_rules! async_assert_fn_sync { ($(!)?Send & Sync & $(!)?Unpin, $value:expr) => { require_sync(&$value); }; ($(!)?Send & !Sync & $(!)?Unpin, $value:expr) => { AmbiguousIfSync::some_item(&$value); }; } macro_rules! async_assert_fn_unpin { ($(!)?Send & $(!)?Sync & Unpin, $value:expr) => { require_unpin(&$value); }; ($(!)?Send & $(!)?Sync & !Unpin, $value:expr) => { AmbiguousIfUnpin::some_item(&$value); }; } macro_rules! async_assert_fn { ($($f:ident $(< $($generic:ty),* > )? )::+($($arg:ty),*): $($tok:tt)*) => { #[allow(unreachable_code)] #[allow(unused_variables)] const _: fn() = || { let f = $($f $(::<$($generic),*>)? )::+( $( into_todo!($arg) ),* ); async_assert_fn_send!($($tok)*, f); async_assert_fn_sync!($($tok)*, f); async_assert_fn_unpin!($($tok)*, f); }; }; } macro_rules! assert_value { ($type:ty: $($tok:tt)*) => { #[allow(unreachable_code)] #[allow(unused_variables)] const _: fn() = || { let f: $type = todo!(); async_assert_fn_send!($($tok)*, f); async_assert_fn_sync!($($tok)*, f); async_assert_fn_unpin!($($tok)*, f); }; }; } assert_value!(tokio::fs::DirBuilder: Send & Sync & Unpin); assert_value!(tokio::fs::DirEntry: Send & Sync & Unpin); assert_value!(tokio::fs::File: Send & Sync & Unpin); assert_value!(tokio::fs::OpenOptions: Send & Sync & Unpin); assert_value!(tokio::fs::ReadDir: Send & Sync & Unpin); async_assert_fn!(tokio::fs::canonicalize(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::copy(&str, &str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::create_dir(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::create_dir_all(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::hard_link(&str, &str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::metadata(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::read(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::read_dir(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::read_link(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::read_to_string(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::remove_dir(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::remove_dir_all(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::remove_file(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::rename(&str, &str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::set_permissions(&str, std::fs::Permissions): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::symlink_metadata(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::write(&str, Vec): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::ReadDir::next_entry(_): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::OpenOptions::open(_, &str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::DirBuilder::create(_, &str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::DirEntry::metadata(_): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::DirEntry::file_type(_): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::File::open(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::File::create(&str): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::File::sync_all(_): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::File::sync_data(_): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::File::set_len(_, u64): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::File::metadata(_): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::File::try_clone(_): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::File::into_std(_): Send & Sync & !Unpin); async_assert_fn!(tokio::fs::File::set_permissions(_, std::fs::Permissions): Send & Sync & !Unpin); assert_value!(tokio::net::TcpListener: Send & Sync & Unpin); assert_value!(tokio::net::TcpSocket: Send & Sync & Unpin); assert_value!(tokio::net::TcpStream: Send & Sync & Unpin); assert_value!(tokio::net::UdpSocket: Send & Sync & Unpin); assert_value!(tokio::net::tcp::OwnedReadHalf: Send & Sync & Unpin); assert_value!(tokio::net::tcp::OwnedWriteHalf: Send & Sync & Unpin); assert_value!(tokio::net::tcp::ReadHalf<'_>: Send & Sync & Unpin); assert_value!(tokio::net::tcp::ReuniteError: Send & Sync & Unpin); assert_value!(tokio::net::tcp::WriteHalf<'_>: Send & Sync & Unpin); async_assert_fn!(tokio::net::TcpListener::accept(_): Send & Sync & !Unpin); async_assert_fn!(tokio::net::TcpListener::bind(SocketAddr): Send & Sync & !Unpin); async_assert_fn!(tokio::net::TcpStream::connect(SocketAddr): Send & Sync & !Unpin); async_assert_fn!(tokio::net::TcpStream::peek(_, &mut [u8]): Send & Sync & !Unpin); async_assert_fn!(tokio::net::TcpStream::readable(_): Send & Sync & !Unpin); async_assert_fn!(tokio::net::TcpStream::ready(_, tokio::io::Interest): Send & Sync & !Unpin); async_assert_fn!(tokio::net::TcpStream::writable(_): Send & Sync & !Unpin); async_assert_fn!(tokio::net::UdpSocket::bind(SocketAddr): Send & Sync & !Unpin); async_assert_fn!(tokio::net::UdpSocket::connect(_, SocketAddr): Send & Sync & !Unpin); async_assert_fn!(tokio::net::UdpSocket::peek_from(_, &mut [u8]): Send & Sync & !Unpin); async_assert_fn!(tokio::net::UdpSocket::readable(_): Send & Sync & !Unpin); async_assert_fn!(tokio::net::UdpSocket::ready(_, tokio::io::Interest): Send & Sync & !Unpin); async_assert_fn!(tokio::net::UdpSocket::recv(_, &mut [u8]): Send & Sync & !Unpin); async_assert_fn!(tokio::net::UdpSocket::recv_from(_, &mut [u8]): Send & Sync & !Unpin); async_assert_fn!(tokio::net::UdpSocket::send(_, &[u8]): Send & Sync & !Unpin); async_assert_fn!(tokio::net::UdpSocket::send_to(_, &[u8], SocketAddr): Send & Sync & !Unpin); async_assert_fn!(tokio::net::UdpSocket::writable(_): Send & Sync & !Unpin); async_assert_fn!(tokio::net::lookup_host(SocketAddr): Send & Sync & !Unpin); async_assert_fn!(tokio::net::tcp::ReadHalf::peek(_, &mut [u8]): Send & Sync & !Unpin); #[cfg(unix)] mod unix_datagram { use super::*; use tokio::net::*; assert_value!(UnixDatagram: Send & Sync & Unpin); assert_value!(UnixListener: Send & Sync & Unpin); assert_value!(UnixStream: Send & Sync & Unpin); assert_value!(unix::OwnedReadHalf: Send & Sync & Unpin); assert_value!(unix::OwnedWriteHalf: Send & Sync & Unpin); assert_value!(unix::ReadHalf<'_>: Send & Sync & Unpin); assert_value!(unix::ReuniteError: Send & Sync & Unpin); assert_value!(unix::SocketAddr: Send & Sync & Unpin); assert_value!(unix::UCred: Send & Sync & Unpin); assert_value!(unix::WriteHalf<'_>: Send & Sync & Unpin); async_assert_fn!(UnixDatagram::readable(_): Send & Sync & !Unpin); async_assert_fn!(UnixDatagram::ready(_, tokio::io::Interest): Send & Sync & !Unpin); async_assert_fn!(UnixDatagram::recv(_, &mut [u8]): Send & Sync & !Unpin); async_assert_fn!(UnixDatagram::recv_from(_, &mut [u8]): Send & Sync & !Unpin); async_assert_fn!(UnixDatagram::send(_, &[u8]): Send & Sync & !Unpin); async_assert_fn!(UnixDatagram::send_to(_, &[u8], &str): Send & Sync & !Unpin); async_assert_fn!(UnixDatagram::writable(_): Send & Sync & !Unpin); async_assert_fn!(UnixListener::accept(_): Send & Sync & !Unpin); async_assert_fn!(UnixStream::connect(&str): Send & Sync & !Unpin); async_assert_fn!(UnixStream::readable(_): Send & Sync & !Unpin); async_assert_fn!(UnixStream::ready(_, tokio::io::Interest): Send & Sync & !Unpin); async_assert_fn!(UnixStream::writable(_): Send & Sync & !Unpin); } #[cfg(windows)] mod windows_named_pipe { use super::*; use tokio::net::windows::named_pipe::*; assert_value!(ClientOptions: Send & Sync & Unpin); assert_value!(NamedPipeClient: Send & Sync & Unpin); assert_value!(NamedPipeServer: Send & Sync & Unpin); assert_value!(PipeEnd: Send & Sync & Unpin); assert_value!(PipeInfo: Send & Sync & Unpin); assert_value!(PipeMode: Send & Sync & Unpin); assert_value!(ServerOptions: Send & Sync & Unpin); async_assert_fn!(NamedPipeClient::readable(_): Send & Sync & !Unpin); async_assert_fn!(NamedPipeClient::ready(_, tokio::io::Interest): Send & Sync & !Unpin); async_assert_fn!(NamedPipeClient::writable(_): Send & Sync & !Unpin); async_assert_fn!(NamedPipeServer::connect(_): Send & Sync & !Unpin); async_assert_fn!(NamedPipeServer::readable(_): Send & Sync & !Unpin); async_assert_fn!(NamedPipeServer::ready(_, tokio::io::Interest): Send & Sync & !Unpin); async_assert_fn!(NamedPipeServer::writable(_): Send & Sync & !Unpin); } assert_value!(tokio::process::Child: Send & Sync & Unpin); assert_value!(tokio::process::ChildStderr: Send & Sync & Unpin); assert_value!(tokio::process::ChildStdin: Send & Sync & Unpin); assert_value!(tokio::process::ChildStdout: Send & Sync & Unpin); assert_value!(tokio::process::Command: Send & Sync & Unpin); async_assert_fn!(tokio::process::Child::kill(_): Send & Sync & !Unpin); async_assert_fn!(tokio::process::Child::wait(_): Send & Sync & !Unpin); async_assert_fn!(tokio::process::Child::wait_with_output(_): Send & Sync & !Unpin); async_assert_fn!(tokio::signal::ctrl_c(): Send & Sync & !Unpin); #[cfg(unix)] mod unix_signal { use super::*; assert_value!(tokio::signal::unix::Signal: Send & Sync & Unpin); assert_value!(tokio::signal::unix::SignalKind: Send & Sync & Unpin); async_assert_fn!(tokio::signal::unix::Signal::recv(_): Send & Sync & !Unpin); } #[cfg(windows)] mod windows_signal { use super::*; assert_value!(tokio::signal::windows::CtrlC: Send & Sync & Unpin); assert_value!(tokio::signal::windows::CtrlBreak: Send & Sync & Unpin); async_assert_fn!(tokio::signal::windows::CtrlC::recv(_): Send & Sync & !Unpin); async_assert_fn!(tokio::signal::windows::CtrlBreak::recv(_): Send & Sync & !Unpin); } assert_value!(tokio::sync::AcquireError: Send & Sync & Unpin); assert_value!(tokio::sync::Barrier: Send & Sync & Unpin); assert_value!(tokio::sync::BarrierWaitResult: Send & Sync & Unpin); assert_value!(tokio::sync::MappedMutexGuard<'_, NN>: !Send & !Sync & Unpin); assert_value!(tokio::sync::MappedMutexGuard<'_, YN>: Send & !Sync & Unpin); assert_value!(tokio::sync::MappedMutexGuard<'_, YY>: Send & Sync & Unpin); assert_value!(tokio::sync::Mutex: !Send & !Sync & Unpin); assert_value!(tokio::sync::Mutex: Send & Sync & Unpin); assert_value!(tokio::sync::Mutex: Send & Sync & Unpin); assert_value!(tokio::sync::MutexGuard<'_, NN>: !Send & !Sync & Unpin); assert_value!(tokio::sync::MutexGuard<'_, YN>: Send & !Sync & Unpin); assert_value!(tokio::sync::MutexGuard<'_, YY>: Send & Sync & Unpin); assert_value!(tokio::sync::Notify: Send & Sync & Unpin); assert_value!(tokio::sync::OnceCell: !Send & !Sync & Unpin); assert_value!(tokio::sync::OnceCell: Send & !Sync & Unpin); assert_value!(tokio::sync::OnceCell: Send & Sync & Unpin); assert_value!(tokio::sync::OwnedMutexGuard: !Send & !Sync & Unpin); assert_value!(tokio::sync::OwnedMutexGuard: Send & !Sync & Unpin); assert_value!(tokio::sync::OwnedMutexGuard: Send & Sync & Unpin); assert_value!(tokio::sync::OwnedRwLockMappedWriteGuard: !Send & !Sync & Unpin); assert_value!(tokio::sync::OwnedRwLockMappedWriteGuard: !Send & !Sync & Unpin); assert_value!(tokio::sync::OwnedRwLockMappedWriteGuard: Send & Sync & Unpin); assert_value!(tokio::sync::OwnedRwLockReadGuard: !Send & !Sync & Unpin); assert_value!(tokio::sync::OwnedRwLockReadGuard: !Send & !Sync & Unpin); assert_value!(tokio::sync::OwnedRwLockReadGuard: Send & Sync & Unpin); assert_value!(tokio::sync::OwnedRwLockWriteGuard: !Send & !Sync & Unpin); assert_value!(tokio::sync::OwnedRwLockWriteGuard: !Send & !Sync & Unpin); assert_value!(tokio::sync::OwnedRwLockWriteGuard: Send & Sync & Unpin); assert_value!(tokio::sync::OwnedSemaphorePermit: Send & Sync & Unpin); assert_value!(tokio::sync::RwLock: !Send & !Sync & Unpin); assert_value!(tokio::sync::RwLock: Send & !Sync & Unpin); assert_value!(tokio::sync::RwLock: Send & Sync & Unpin); assert_value!(tokio::sync::RwLockMappedWriteGuard<'_, NN>: !Send & !Sync & Unpin); assert_value!(tokio::sync::RwLockMappedWriteGuard<'_, YN>: !Send & !Sync & Unpin); assert_value!(tokio::sync::RwLockMappedWriteGuard<'_, YY>: Send & Sync & Unpin); assert_value!(tokio::sync::RwLockReadGuard<'_, NN>: !Send & !Sync & Unpin); assert_value!(tokio::sync::RwLockReadGuard<'_, YN>: !Send & !Sync & Unpin); assert_value!(tokio::sync::RwLockReadGuard<'_, YY>: Send & Sync & Unpin); assert_value!(tokio::sync::RwLockWriteGuard<'_, NN>: !Send & !Sync & Unpin); assert_value!(tokio::sync::RwLockWriteGuard<'_, YN>: !Send & !Sync & Unpin); assert_value!(tokio::sync::RwLockWriteGuard<'_, YY>: Send & Sync & Unpin); assert_value!(tokio::sync::Semaphore: Send & Sync & Unpin); assert_value!(tokio::sync::SemaphorePermit<'_>: Send & Sync & Unpin); assert_value!(tokio::sync::TryAcquireError: Send & Sync & Unpin); assert_value!(tokio::sync::TryLockError: Send & Sync & Unpin); assert_value!(tokio::sync::broadcast::Receiver: !Send & !Sync & Unpin); assert_value!(tokio::sync::broadcast::Receiver: Send & Sync & Unpin); assert_value!(tokio::sync::broadcast::Receiver: Send & Sync & Unpin); assert_value!(tokio::sync::broadcast::Sender: !Send & !Sync & Unpin); assert_value!(tokio::sync::broadcast::Sender: Send & Sync & Unpin); assert_value!(tokio::sync::broadcast::Sender: Send & Sync & Unpin); assert_value!(tokio::sync::futures::Notified<'_>: Send & Sync & !Unpin); assert_value!(tokio::sync::mpsc::OwnedPermit: !Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::OwnedPermit: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::OwnedPermit: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::Permit<'_, NN>: !Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::Permit<'_, YN>: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::Permit<'_, YY>: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::Receiver: !Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::Receiver: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::Receiver: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::Sender: !Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::Sender: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::Sender: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::UnboundedReceiver: !Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::UnboundedReceiver: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::UnboundedReceiver: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::UnboundedSender: !Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::UnboundedSender: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::UnboundedSender: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::error::SendError: !Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::error::SendError: Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::error::SendError: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::error::SendTimeoutError: !Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::error::SendTimeoutError: Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::error::SendTimeoutError: Send & Sync & Unpin); assert_value!(tokio::sync::mpsc::error::TrySendError: !Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::error::TrySendError: Send & !Sync & Unpin); assert_value!(tokio::sync::mpsc::error::TrySendError: Send & Sync & Unpin); assert_value!(tokio::sync::oneshot::Receiver: !Send & !Sync & Unpin); assert_value!(tokio::sync::oneshot::Receiver: Send & Sync & Unpin); assert_value!(tokio::sync::oneshot::Receiver: Send & Sync & Unpin); assert_value!(tokio::sync::oneshot::Sender: !Send & !Sync & Unpin); assert_value!(tokio::sync::oneshot::Sender: Send & Sync & Unpin); assert_value!(tokio::sync::oneshot::Sender: Send & Sync & Unpin); assert_value!(tokio::sync::watch::Receiver: !Send & !Sync & Unpin); assert_value!(tokio::sync::watch::Receiver: !Send & !Sync & Unpin); assert_value!(tokio::sync::watch::Receiver: Send & Sync & Unpin); assert_value!(tokio::sync::watch::Ref<'_, NN>: !Send & !Sync & Unpin); assert_value!(tokio::sync::watch::Ref<'_, YN>: !Send & !Sync & Unpin); assert_value!(tokio::sync::watch::Ref<'_, YY>: !Send & Sync & Unpin); assert_value!(tokio::sync::watch::Sender: !Send & !Sync & Unpin); assert_value!(tokio::sync::watch::Sender: !Send & !Sync & Unpin); assert_value!(tokio::sync::watch::Sender: Send & Sync & Unpin); async_assert_fn!(tokio::sync::Barrier::wait(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::Mutex::lock(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::Mutex::lock_owned(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::Mutex::lock(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::Mutex::lock_owned(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::Mutex::lock(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::Mutex::lock_owned(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::Notify::notified(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_init( _, fn() -> Pin + Send + Sync>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_init( _, fn() -> Pin + Send>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_init( _, fn() -> Pin>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_try_init( _, fn() -> Pin> + Send + Sync>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_try_init( _, fn() -> Pin> + Send>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_try_init( _, fn() -> Pin>>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_init( _, fn() -> Pin + Send + Sync>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_init( _, fn() -> Pin + Send>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_init( _, fn() -> Pin>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_try_init( _, fn() -> Pin> + Send + Sync>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_try_init( _, fn() -> Pin> + Send>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_try_init( _, fn() -> Pin>>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_init( _, fn() -> Pin + Send + Sync>>): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_init( _, fn() -> Pin + Send>>): Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_init( _, fn() -> Pin>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_try_init( _, fn() -> Pin> + Send + Sync>>): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_try_init( _, fn() -> Pin> + Send>>): Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::OnceCell::get_or_try_init( _, fn() -> Pin>>>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::RwLock::read(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::RwLock::write(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::RwLock::read(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::RwLock::write(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::RwLock::read(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::RwLock::write(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::Semaphore::acquire(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::Semaphore::acquire_many(_, u32): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::Semaphore::acquire_many_owned(_, u32): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::Semaphore::acquire_owned(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::broadcast::Receiver::recv(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::broadcast::Receiver::recv(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::broadcast::Receiver::recv(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Receiver::recv(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Receiver::recv(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Receiver::recv(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::closed(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::reserve(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::reserve_owned(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::send(_, NN): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::send_timeout(_, NN, Duration): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::closed(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::reserve(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::reserve_owned(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::send(_, YN): Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::send_timeout(_, YN, Duration): Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::closed(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::reserve(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::reserve_owned(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::send(_, YY): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::Sender::send_timeout(_, YY, Duration): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::UnboundedReceiver::recv(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::UnboundedReceiver::recv(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::UnboundedReceiver::recv(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::UnboundedSender::closed(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::UnboundedSender::closed(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::mpsc::UnboundedSender::closed(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::oneshot::Sender::closed(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::oneshot::Sender::closed(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::oneshot::Sender::closed(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::watch::Receiver::changed(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::watch::Receiver::changed(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::watch::Receiver::changed(_): Send & Sync & !Unpin); async_assert_fn!(tokio::sync::watch::Sender::closed(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::watch::Sender::closed(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::sync::watch::Sender::closed(_): Send & Sync & !Unpin); async_assert_fn!(tokio::task::LocalKey>::scope(_, Cell, BoxFuture<()>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::task::LocalKey>::scope(_, Cell, BoxFutureSend<()>): Send & !Sync & !Unpin); async_assert_fn!(tokio::task::LocalKey>::scope(_, Cell, BoxFutureSync<()>): Send & !Sync & !Unpin); async_assert_fn!(tokio::task::LocalKey>::scope(_, Rc, BoxFuture<()>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::task::LocalKey>::scope(_, Rc, BoxFutureSend<()>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::task::LocalKey>::scope(_, Rc, BoxFutureSync<()>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::task::LocalKey::scope(_, u32, BoxFuture<()>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::task::LocalKey::scope(_, u32, BoxFutureSend<()>): Send & !Sync & !Unpin); async_assert_fn!(tokio::task::LocalKey::scope(_, u32, BoxFutureSync<()>): Send & Sync & !Unpin); async_assert_fn!(tokio::task::LocalSet::run_until(_, BoxFutureSync<()>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::task::unconstrained(BoxFuture<()>): !Send & !Sync & Unpin); async_assert_fn!(tokio::task::unconstrained(BoxFutureSend<()>): Send & !Sync & Unpin); async_assert_fn!(tokio::task::unconstrained(BoxFutureSync<()>): Send & Sync & Unpin); assert_value!(tokio::task::JoinError: Send & Sync & Unpin); assert_value!(tokio::task::JoinHandle: !Send & !Sync & Unpin); assert_value!(tokio::task::JoinHandle: Send & Sync & Unpin); assert_value!(tokio::task::JoinHandle: Send & Sync & Unpin); #[cfg(tokio_unstable)] mod unstable { use super::*; async_assert_fn!(tokio::task::JoinSet>::join_one(_): Send & Sync & !Unpin); async_assert_fn!(tokio::task::JoinSet>::shutdown(_): Send & Sync & !Unpin); async_assert_fn!(tokio::task::JoinSet>::join_one(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::task::JoinSet>::shutdown(_): !Send & !Sync & !Unpin); async_assert_fn!(tokio::task::JoinSet::join_one(_): Send & Sync & !Unpin); async_assert_fn!(tokio::task::JoinSet::shutdown(_): Send & Sync & !Unpin); assert_value!(tokio::task::JoinSet: Send & Sync & Unpin); assert_value!(tokio::task::JoinSet: Send & Sync & Unpin); assert_value!(tokio::task::JoinSet: !Send & !Sync & Unpin); assert_value!(tokio::task::LocalSet: !Send & !Sync & Unpin); } assert_value!(tokio::runtime::Builder: Send & Sync & Unpin); assert_value!(tokio::runtime::EnterGuard<'_>: Send & Sync & Unpin); assert_value!(tokio::runtime::Handle: Send & Sync & Unpin); assert_value!(tokio::runtime::Runtime: Send & Sync & Unpin); assert_value!(tokio::time::Interval: Send & Sync & Unpin); assert_value!(tokio::time::Instant: Send & Sync & Unpin); assert_value!(tokio::time::Sleep: Send & Sync & !Unpin); assert_value!(tokio::time::Timeout>: Send & Sync & !Unpin); assert_value!(tokio::time::Timeout>: Send & !Sync & !Unpin); assert_value!(tokio::time::Timeout>: !Send & !Sync & !Unpin); assert_value!(tokio::time::error::Elapsed: Send & Sync & Unpin); assert_value!(tokio::time::error::Error: Send & Sync & Unpin); async_assert_fn!(tokio::time::advance(Duration): Send & Sync & !Unpin); async_assert_fn!(tokio::time::sleep(Duration): Send & Sync & !Unpin); async_assert_fn!(tokio::time::sleep_until(Instant): Send & Sync & !Unpin); async_assert_fn!(tokio::time::timeout(Duration, BoxFutureSync<()>): Send & Sync & !Unpin); async_assert_fn!(tokio::time::timeout(Duration, BoxFutureSend<()>): Send & !Sync & !Unpin); async_assert_fn!(tokio::time::timeout(Duration, BoxFuture<()>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::time::timeout_at(Instant, BoxFutureSync<()>): Send & Sync & !Unpin); async_assert_fn!(tokio::time::timeout_at(Instant, BoxFutureSend<()>): Send & !Sync & !Unpin); async_assert_fn!(tokio::time::timeout_at(Instant, BoxFuture<()>): !Send & !Sync & !Unpin); async_assert_fn!(tokio::time::Interval::tick(_): Send & Sync & !Unpin); assert_value!(tokio::io::BufReader: Send & Sync & Unpin); assert_value!(tokio::io::BufStream: Send & Sync & Unpin); assert_value!(tokio::io::BufWriter: Send & Sync & Unpin); assert_value!(tokio::io::DuplexStream: Send & Sync & Unpin); assert_value!(tokio::io::Empty: Send & Sync & Unpin); assert_value!(tokio::io::Interest: Send & Sync & Unpin); assert_value!(tokio::io::Lines: Send & Sync & Unpin); assert_value!(tokio::io::ReadBuf<'_>: Send & Sync & Unpin); assert_value!(tokio::io::ReadHalf: Send & Sync & Unpin); assert_value!(tokio::io::Ready: Send & Sync & Unpin); assert_value!(tokio::io::Repeat: Send & Sync & Unpin); assert_value!(tokio::io::Sink: Send & Sync & Unpin); assert_value!(tokio::io::Split: Send & Sync & Unpin); assert_value!(tokio::io::Stderr: Send & Sync & Unpin); assert_value!(tokio::io::Stdin: Send & Sync & Unpin); assert_value!(tokio::io::Stdout: Send & Sync & Unpin); assert_value!(tokio::io::Take: Send & Sync & Unpin); assert_value!(tokio::io::WriteHalf: Send & Sync & Unpin); async_assert_fn!(tokio::io::copy(&mut TcpStream, &mut TcpStream): Send & Sync & !Unpin); async_assert_fn!( tokio::io::copy_bidirectional(&mut TcpStream, &mut TcpStream): Send & Sync & !Unpin ); async_assert_fn!(tokio::io::copy_buf(&mut tokio::io::BufReader, &mut TcpStream): Send & Sync & !Unpin); async_assert_fn!(tokio::io::empty(): Send & Sync & Unpin); async_assert_fn!(tokio::io::repeat(u8): Send & Sync & Unpin); async_assert_fn!(tokio::io::sink(): Send & Sync & Unpin); async_assert_fn!(tokio::io::split(TcpStream): Send & Sync & Unpin); async_assert_fn!(tokio::io::stderr(): Send & Sync & Unpin); async_assert_fn!(tokio::io::stdin(): Send & Sync & Unpin); async_assert_fn!(tokio::io::stdout(): Send & Sync & Unpin); async_assert_fn!(tokio::io::Split>::next_segment(_): Send & Sync & !Unpin); async_assert_fn!(tokio::io::Lines>::next_line(_): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncBufReadExt::read_until(&mut BoxAsyncRead, u8, &mut Vec): Send & Sync & !Unpin); async_assert_fn!( tokio::io::AsyncBufReadExt::read_line(&mut BoxAsyncRead, &mut String): Send & Sync & !Unpin ); async_assert_fn!(tokio::io::AsyncBufReadExt::fill_buf(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read(&mut BoxAsyncRead, &mut [u8]): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_buf(&mut BoxAsyncRead, &mut Vec): Send & Sync & !Unpin); async_assert_fn!( tokio::io::AsyncReadExt::read_exact(&mut BoxAsyncRead, &mut [u8]): Send & Sync & !Unpin ); async_assert_fn!(tokio::io::AsyncReadExt::read_u8(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_i8(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_u16(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_i16(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_u32(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_i32(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_u64(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_i64(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_u128(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_i128(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_f32(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_f64(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_u16_le(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_i16_le(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_u32_le(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_i32_le(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_u64_le(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_i64_le(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_u128_le(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_i128_le(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_f32_le(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_f64_le(&mut BoxAsyncRead): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncReadExt::read_to_end(&mut BoxAsyncRead, &mut Vec): Send & Sync & !Unpin); async_assert_fn!( tokio::io::AsyncReadExt::read_to_string(&mut BoxAsyncRead, &mut String): Send & Sync & !Unpin ); async_assert_fn!(tokio::io::AsyncSeekExt::seek(&mut BoxAsyncSeek, SeekFrom): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncSeekExt::stream_position(&mut BoxAsyncSeek): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncWriteExt::write(&mut BoxAsyncWrite, &[u8]): Send & Sync & !Unpin); async_assert_fn!( tokio::io::AsyncWriteExt::write_vectored(&mut BoxAsyncWrite, _): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_buf(&mut BoxAsyncWrite, &mut bytes::Bytes): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_all_buf(&mut BoxAsyncWrite, &mut bytes::Bytes): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_all(&mut BoxAsyncWrite, &[u8]): Send & Sync & !Unpin ); async_assert_fn!(tokio::io::AsyncWriteExt::write_u8(&mut BoxAsyncWrite, u8): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncWriteExt::write_i8(&mut BoxAsyncWrite, i8): Send & Sync & !Unpin); async_assert_fn!( tokio::io::AsyncWriteExt::write_u16(&mut BoxAsyncWrite, u16): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_i16(&mut BoxAsyncWrite, i16): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_u32(&mut BoxAsyncWrite, u32): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_i32(&mut BoxAsyncWrite, i32): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_u64(&mut BoxAsyncWrite, u64): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_i64(&mut BoxAsyncWrite, i64): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_u128(&mut BoxAsyncWrite, u128): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_i128(&mut BoxAsyncWrite, i128): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_f32(&mut BoxAsyncWrite, f32): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_f64(&mut BoxAsyncWrite, f64): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_u16_le(&mut BoxAsyncWrite, u16): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_i16_le(&mut BoxAsyncWrite, i16): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_u32_le(&mut BoxAsyncWrite, u32): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_i32_le(&mut BoxAsyncWrite, i32): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_u64_le(&mut BoxAsyncWrite, u64): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_i64_le(&mut BoxAsyncWrite, i64): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_u128_le(&mut BoxAsyncWrite, u128): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_i128_le(&mut BoxAsyncWrite, i128): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_f32_le(&mut BoxAsyncWrite, f32): Send & Sync & !Unpin ); async_assert_fn!( tokio::io::AsyncWriteExt::write_f64_le(&mut BoxAsyncWrite, f64): Send & Sync & !Unpin ); async_assert_fn!(tokio::io::AsyncWriteExt::flush(&mut BoxAsyncWrite): Send & Sync & !Unpin); async_assert_fn!(tokio::io::AsyncWriteExt::shutdown(&mut BoxAsyncWrite): Send & Sync & !Unpin); #[cfg(unix)] mod unix_asyncfd { use super::*; use tokio::io::unix::*; struct ImplsFd { _t: T, } impl std::os::unix::io::AsRawFd for ImplsFd { fn as_raw_fd(&self) -> std::os::unix::io::RawFd { unreachable!() } } assert_value!(AsyncFd>: Send & Sync & Unpin); assert_value!(AsyncFd>: Send & !Sync & Unpin); assert_value!(AsyncFd>: !Send & !Sync & Unpin); assert_value!(AsyncFdReadyGuard<'_, ImplsFd>: Send & Sync & Unpin); assert_value!(AsyncFdReadyGuard<'_, ImplsFd>: !Send & !Sync & Unpin); assert_value!(AsyncFdReadyGuard<'_, ImplsFd>: !Send & !Sync & Unpin); assert_value!(AsyncFdReadyMutGuard<'_, ImplsFd>: Send & Sync & Unpin); assert_value!(AsyncFdReadyMutGuard<'_, ImplsFd>: Send & !Sync & Unpin); assert_value!(AsyncFdReadyMutGuard<'_, ImplsFd>: !Send & !Sync & Unpin); assert_value!(TryIoError: Send & Sync & Unpin); async_assert_fn!(AsyncFd>::readable(_): Send & Sync & !Unpin); async_assert_fn!(AsyncFd>::readable_mut(_): Send & Sync & !Unpin); async_assert_fn!(AsyncFd>::writable(_): Send & Sync & !Unpin); async_assert_fn!(AsyncFd>::writable_mut(_): Send & Sync & !Unpin); async_assert_fn!(AsyncFd>::readable(_): !Send & !Sync & !Unpin); async_assert_fn!(AsyncFd>::readable_mut(_): Send & !Sync & !Unpin); async_assert_fn!(AsyncFd>::writable(_): !Send & !Sync & !Unpin); async_assert_fn!(AsyncFd>::writable_mut(_): Send & !Sync & !Unpin); async_assert_fn!(AsyncFd>::readable(_): !Send & !Sync & !Unpin); async_assert_fn!(AsyncFd>::readable_mut(_): !Send & !Sync & !Unpin); async_assert_fn!(AsyncFd>::writable(_): !Send & !Sync & !Unpin); async_assert_fn!(AsyncFd>::writable_mut(_): !Send & !Sync & !Unpin); }