[−][src]Struct bastion::io::Handle
Handle that manages IO submitted to proactor system.
This handle wraps io element, its' completion channel, if file, file buffers and input output operations It is single handedly responsible for dispatching correct operations to IO driver. Speed of IO bound to speed of executor, handle neither interferes with executor nor tightly coupled.
Implementations
impl<T> Handle<T>
[src]
pub fn get_ref(&self) -> &T
[src]
pub fn get_mut(&mut self) -> &mut T
[src]
pub fn into_inner(self) -> T
[src]
impl<T> Handle<T> where
T: AsRawFd,
[src]
T: AsRawFd,
impl Handle<TcpListener>
[src]
pub fn bind<A>(addr: A) -> Result<Handle<TcpListener>, Error> where
A: ToSocketAddrs,
[src]
A: ToSocketAddrs,
pub async fn accept(&'_ self) -> Result<(Handle<TcpStream>, SocketAddr), Error>
[src]
pub fn incoming(
&self
) -> impl Send + Unpin + Stream<Item = Result<Handle<TcpStream>, Error>>
[src]
&self
) -> impl Send + Unpin + Stream<Item = Result<Handle<TcpStream>, Error>>
impl Handle<TcpStream>
[src]
pub async fn connect<A>(sock_addrs: A) -> Result<Handle<TcpStream>, Error> where
A: ToSocketAddrs,
[src]
A: ToSocketAddrs,
pub async fn send(&'_ self, buf: &'_ [u8]) -> Result<usize, Error>
[src]
pub async fn recv(&'_ self, buf: &'_ mut [u8]) -> Result<usize, Error>
[src]
pub async fn peek(&'_ self, buf: &'_ mut [u8]) -> Result<usize, Error>
[src]
impl Handle<UdpSocket>
[src]
pub fn bind<A>(addr: A) -> Result<Handle<UdpSocket>, Error> where
A: ToSocketAddrs,
[src]
A: ToSocketAddrs,
pub async fn connect<A>(sock_addrs: A) -> Result<Handle<UdpSocket>, Error> where
A: ToSocketAddrs,
[src]
A: ToSocketAddrs,
pub async fn send(&'_ self, buf: &'_ [u8]) -> Result<usize, Error>
[src]
pub async fn recv(&'_ self, buf: &'_ mut [u8]) -> Result<usize, Error>
[src]
pub async fn peek(&'_ self, buf: &'_ mut [u8]) -> Result<usize, Error>
[src]
pub async fn send_to<A>(
&'_ self,
buf: &'_ [u8],
addr: A
) -> Result<usize, Error> where
A: ToSocketAddrs,
[src]
&'_ self,
buf: &'_ [u8],
addr: A
) -> Result<usize, Error> where
A: ToSocketAddrs,
pub async fn recv_from(
&'_ self,
buf: &'_ mut [u8]
) -> Result<(usize, SocketAddr), Error>
[src]
&'_ self,
buf: &'_ mut [u8]
) -> Result<(usize, SocketAddr), Error>
pub async fn peek_from(
&'_ self,
buf: &'_ mut [u8]
) -> Result<(usize, SocketAddr), Error>
[src]
&'_ self,
buf: &'_ mut [u8]
) -> Result<(usize, SocketAddr), Error>
impl Handle<UnixListener>
[src]
pub fn bind<P>(path: P) -> Result<Handle<UnixListener>, Error> where
P: AsRef<Path>,
[src]
P: AsRef<Path>,
pub async fn accept(&'_ self) -> Result<(Handle<UnixStream>, SocketAddr), Error>
[src]
pub fn incoming(
&self
) -> impl Send + Unpin + Stream<Item = Result<Handle<UnixStream>, Error>>
[src]
&self
) -> impl Send + Unpin + Stream<Item = Result<Handle<UnixStream>, Error>>
impl Handle<UnixStream>
[src]
pub async fn connect<P>(path: P) -> Result<Handle<UnixStream>, Error> where
P: AsRef<Path>,
[src]
P: AsRef<Path>,
pub fn pair() -> Result<(Handle<UnixStream>, Handle<UnixStream>), Error>
[src]
pub async fn send(&'_ self, buf: &'_ [u8]) -> Result<usize, Error>
[src]
pub async fn recv(&'_ self, buf: &'_ mut [u8]) -> Result<usize, Error>
[src]
pub async fn peek(&'_ self, buf: &'_ mut [u8]) -> Result<usize, Error>
[src]
impl Handle<UnixDatagram>
[src]
pub fn bind<P>(path: P) -> Result<Handle<UnixDatagram>, Error> where
P: AsRef<Path>,
[src]
P: AsRef<Path>,
pub fn pair() -> Result<(Handle<UnixDatagram>, Handle<UnixDatagram>), Error>
[src]
pub async fn send(&'_ self, buf: &'_ [u8]) -> Result<usize, Error>
[src]
pub async fn recv(&'_ self, buf: &'_ mut [u8]) -> Result<usize, Error>
[src]
pub async fn peek(&'_ self, buf: &'_ mut [u8]) -> Result<usize, Error>
[src]
pub async fn send_to<P>(
&'_ self,
buf: &'_ [u8],
path: P
) -> Result<usize, Error> where
P: AsRef<Path>,
[src]
&'_ self,
buf: &'_ [u8],
path: P
) -> Result<usize, Error> where
P: AsRef<Path>,
pub async fn recv_from(
&'_ self,
buf: &'_ mut [u8]
) -> Result<(usize, SocketAddr), Error>
[src]
&'_ self,
buf: &'_ mut [u8]
) -> Result<(usize, SocketAddr), Error>
pub async fn peek_from(
&'_ self,
buf: &'_ mut [u8]
) -> Result<(usize, SocketAddr), Error>
[src]
&'_ self,
buf: &'_ mut [u8]
) -> Result<(usize, SocketAddr), Error>
Trait Implementations
impl<T> AsRawFd for Handle<T> where
T: AsRawFd,
[src]
T: AsRawFd,
impl<'_> AsyncRead for &'_ Handle<File>
[src]
fn poll_read(
self: Pin<&mut &'_ Handle<File>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut &'_ Handle<File>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
fn poll_read_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
impl AsyncRead for Handle<TcpStream>
[src]
fn poll_read(
self: Pin<&mut Handle<TcpStream>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Handle<TcpStream>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
fn poll_read_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
impl<'_> AsyncRead for &'_ Handle<TcpStream>
[src]
fn poll_read(
self: Pin<&mut &'_ Handle<TcpStream>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut &'_ Handle<TcpStream>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
fn poll_read_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
impl AsyncRead for Handle<UnixStream>
[src]
fn poll_read(
self: Pin<&mut Handle<UnixStream>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Handle<UnixStream>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
fn poll_read_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
impl AsyncRead for Handle<File>
[src]
fn poll_read(
self: Pin<&mut Handle<File>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Handle<File>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
fn poll_read_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
impl<'_> AsyncRead for &'_ Handle<UnixStream>
[src]
fn poll_read(
self: Pin<&mut &'_ Handle<UnixStream>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut &'_ Handle<UnixStream>>,
cx: &mut Context,
buf: &mut [u8]
) -> Poll<Result<usize, Error>>
fn poll_read_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>
impl AsyncSeek for Handle<File>
[src]
fn poll_seek(
self: Pin<&mut Handle<File>>,
cx: &mut Context,
pos: SeekFrom
) -> Poll<Result<u64, Error>>
[src]
self: Pin<&mut Handle<File>>,
cx: &mut Context,
pos: SeekFrom
) -> Poll<Result<u64, Error>>
impl<'_> AsyncWrite for &'_ Handle<TcpStream>
[src]
fn poll_write(
self: Pin<&mut &'_ Handle<TcpStream>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut &'_ Handle<TcpStream>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
fn poll_flush(
self: Pin<&mut &'_ Handle<TcpStream>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut &'_ Handle<TcpStream>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_close(
self: Pin<&mut &'_ Handle<TcpStream>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut &'_ Handle<TcpStream>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_write_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
impl AsyncWrite for Handle<TcpStream>
[src]
fn poll_write(
self: Pin<&mut Handle<TcpStream>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Handle<TcpStream>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
fn poll_flush(
self: Pin<&mut Handle<TcpStream>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut Handle<TcpStream>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_close(
self: Pin<&mut Handle<TcpStream>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut Handle<TcpStream>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_write_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
impl<'_> AsyncWrite for &'_ Handle<UnixStream>
[src]
fn poll_write(
self: Pin<&mut &'_ Handle<UnixStream>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut &'_ Handle<UnixStream>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
fn poll_flush(
self: Pin<&mut &'_ Handle<UnixStream>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut &'_ Handle<UnixStream>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_close(
self: Pin<&mut &'_ Handle<UnixStream>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut &'_ Handle<UnixStream>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_write_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
impl<'_> AsyncWrite for &'_ Handle<File>
[src]
fn poll_write(
self: Pin<&mut &'_ Handle<File>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut &'_ Handle<File>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
fn poll_flush(
self: Pin<&mut &'_ Handle<File>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut &'_ Handle<File>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_close(
self: Pin<&mut &'_ Handle<File>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut &'_ Handle<File>>,
_cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_write_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
impl AsyncWrite for Handle<UnixStream>
[src]
fn poll_write(
self: Pin<&mut Handle<UnixStream>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Handle<UnixStream>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
fn poll_flush(
self: Pin<&mut Handle<UnixStream>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut Handle<UnixStream>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_close(
self: Pin<&mut Handle<UnixStream>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut Handle<UnixStream>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_write_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
impl AsyncWrite for Handle<File>
[src]
fn poll_write(
self: Pin<&mut Handle<File>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Handle<File>>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize, Error>>
fn poll_flush(
self: Pin<&mut Handle<File>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut Handle<File>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_close(
self: Pin<&mut Handle<File>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
[src]
self: Pin<&mut Handle<File>>,
cx: &mut Context
) -> Poll<Result<(), Error>>
fn poll_write_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
impl<T> Debug for Handle<T> where
T: Debug,
[src]
T: Debug,
impl<T> Deref for Handle<T>
[src]
type Target = T
The resulting type after dereferencing.
fn deref(&self) -> &<Handle<T> as Deref>::Target
[src]
impl<T> DerefMut for Handle<T>
[src]
impl<'_, T> HandleOpRegisterer for &'_ Handle<T>
[src]
fn read_registerer(
&self
) -> Arc<TTas<Option<Pin<Box<dyn Future<Output = Result<usize, Error>> + 'static>>>>>
[src]
&self
) -> Arc<TTas<Option<Pin<Box<dyn Future<Output = Result<usize, Error>> + 'static>>>>>
fn write_registerer(
&self
) -> Arc<TTas<Option<Pin<Box<dyn Future<Output = Result<usize, Error>> + 'static>>>>>
[src]
&self
) -> Arc<TTas<Option<Pin<Box<dyn Future<Output = Result<usize, Error>> + 'static>>>>>
impl<T> HandleOpRegisterer for Handle<T>
[src]
fn read_registerer(
&self
) -> Arc<TTas<Option<Pin<Box<dyn Future<Output = Result<usize, Error>> + 'static>>>>>
[src]
&self
) -> Arc<TTas<Option<Pin<Box<dyn Future<Output = Result<usize, Error>> + 'static>>>>>
fn write_registerer(
&self
) -> Arc<TTas<Option<Pin<Box<dyn Future<Output = Result<usize, Error>> + 'static>>>>>
[src]
&self
) -> Arc<TTas<Option<Pin<Box<dyn Future<Output = Result<usize, Error>> + 'static>>>>>
impl<T> IntoRawFd for Handle<T> where
T: IntoRawFd,
[src]
T: IntoRawFd,
fn into_raw_fd(self) -> i32
[src]
impl<T> Send for Handle<T>
[src]
impl<T> Sync for Handle<T>
[src]
Auto Trait Implementations
impl<T> !RefUnwindSafe for Handle<T>
impl<T> Unpin for Handle<T> where
T: Unpin,
T: Unpin,
impl<T> !UnwindSafe for Handle<T>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> AsAny for T where
T: Any,
[src]
T: Any,
impl<R> AsyncReadExt for R where
R: AsyncRead + ?Sized,
[src]
R: AsyncRead + ?Sized,
fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,
[src]
R: AsyncRead,
fn read(&'a mut self, buf: &'a mut [u8]) -> Read<'a, Self> where
Self: Unpin,
[src]
Self: Unpin,
fn read_vectored(
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectored<'a, Self> where
Self: Unpin,
[src]
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectored<'a, Self> where
Self: Unpin,
fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExact<'a, Self> where
Self: Unpin,
[src]
Self: Unpin,
fn read_to_end(&'a mut self, buf: &'a mut Vec<u8>) -> ReadToEnd<'a, Self> where
Self: Unpin,
[src]
Self: Unpin,
fn read_to_string(&'a mut self, buf: &'a mut String) -> ReadToString<'a, Self> where
Self: Unpin,
[src]
Self: Unpin,
fn split(self) -> (ReadHalf<Self>, WriteHalf<Self>) where
Self: AsyncWrite,
[src]
Self: AsyncWrite,
fn take(self, limit: u64) -> Take<Self>
[src]
impl<R> AsyncReadExt for R where
R: AsyncRead + ?Sized,
R: AsyncRead + ?Sized,
fn read(&'a mut self, buf: &'a mut [u8]) -> ReadFuture<'a, Self> where
Self: Unpin,
Self: Unpin,
fn read_vectored(
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self> where
Self: Unpin,
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self> where
Self: Unpin,
fn read_to_end(&'a mut self, buf: &'a mut Vec<u8>) -> ReadToEndFuture<'a, Self> where
Self: Unpin,
Self: Unpin,
fn read_to_string(
&'a mut self,
buf: &'a mut String
) -> ReadToStringFuture<'a, Self> where
Self: Unpin,
&'a mut self,
buf: &'a mut String
) -> ReadToStringFuture<'a, Self> where
Self: Unpin,
fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExactFuture<'a, Self> where
Self: Unpin,
Self: Unpin,
fn take(self, limit: u64) -> Take<Self>
fn bytes(self) -> Bytes<Self>
fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,
R: AsyncRead,
impl<S> AsyncSeekExt for S where
S: AsyncSeek + ?Sized,
[src]
S: AsyncSeek + ?Sized,
impl<S> AsyncSeekExt for S where
S: AsyncSeek + ?Sized,
S: AsyncSeek + ?Sized,
impl<W> AsyncWriteExt for W where
W: AsyncWrite + ?Sized,
[src]
W: AsyncWrite + ?Sized,
fn flush(&mut self) -> Flush<Self> where
Self: Unpin,
[src]
Self: Unpin,
fn close(&mut self) -> Close<Self> where
Self: Unpin,
[src]
Self: Unpin,
fn write(&'a mut self, buf: &'a [u8]) -> Write<'a, Self> where
Self: Unpin,
[src]
Self: Unpin,
fn write_vectored(
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectored<'a, Self> where
Self: Unpin,
[src]
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectored<'a, Self> where
Self: Unpin,
fn write_all(&'a mut self, buf: &'a [u8]) -> WriteAll<'a, Self> where
Self: Unpin,
[src]
Self: Unpin,
fn into_sink<Item>(self) -> IntoSink<Self, Item> where
Item: AsRef<[u8]>,
[src]
Item: AsRef<[u8]>,
impl<R> AsyncWriteExt for R where
R: AsyncWrite + ?Sized,
R: AsyncWrite + ?Sized,
fn write(&'a mut self, buf: &'a [u8]) -> WriteFuture<'a, Self> where
Self: Unpin,
Self: Unpin,
fn write_vectored(
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectoredFuture<'a, Self> where
Self: Unpin,
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectoredFuture<'a, Self> where
Self: Unpin,
fn write_all(&'a mut self, buf: &'a [u8]) -> WriteAllFuture<'a, Self> where
Self: Unpin,
Self: Unpin,
fn flush(&mut self) -> FlushFuture<Self> where
Self: Unpin,
Self: Unpin,
fn close(&mut self) -> CloseFuture<Self> where
Self: Unpin,
Self: Unpin,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Message for T where
T: Any + Send + Sync + Debug,
[src]
T: Any + Send + Sync + Debug,
impl<T> ReadExt for T where
T: AsyncRead + ?Sized,
T: AsyncRead + ?Sized,
fn read(&'a mut self, buf: &'a mut [u8]) -> ReadFuture<'a, Self> where
Self: Unpin,
Self: Unpin,
fn read_vectored(
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self> where
Self: Unpin,
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self> where
Self: Unpin,
fn read_to_end(&'a mut self, buf: &'a mut Vec<u8>) -> ReadToEndFuture<'a, Self> where
Self: Unpin,
Self: Unpin,
fn read_to_string(
&'a mut self,
buf: &'a mut String
) -> ReadToStringFuture<'a, Self> where
Self: Unpin,
&'a mut self,
buf: &'a mut String
) -> ReadToStringFuture<'a, Self> where
Self: Unpin,
fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExactFuture<'a, Self> where
Self: Unpin,
Self: Unpin,
fn take(self, limit: u64) -> Take<Self>
fn by_ref(&mut self) -> &mut Self
fn bytes(self) -> Bytes<Self>
fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,
R: AsyncRead,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T> SeekExt for T where
T: AsyncSeek + ?Sized,
T: AsyncSeek + ?Sized,
impl<T> State for T where
T: Send + Sync + 'static,
[src]
T: Send + Sync + 'static,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
fn vzip(self) -> V
impl<T> WriteExt for T where
T: AsyncWrite + ?Sized,
T: AsyncWrite + ?Sized,
fn write(&'a mut self, buf: &'a [u8]) -> WriteFuture<'a, Self> where
Self: Unpin,
Self: Unpin,
fn flush(&mut self) -> FlushFuture<Self> where
Self: Unpin,
Self: Unpin,
fn write_vectored(
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectoredFuture<'a, Self> where
Self: Unpin,
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectoredFuture<'a, Self> where
Self: Unpin,
fn write_all(&'a mut self, buf: &'a [u8]) -> WriteAllFuture<'a, Self> where
Self: Unpin,
Self: Unpin,
fn write_fmt(&'a mut self, fmt: Arguments) -> WriteFmtFuture<'a, Self> where
Self: Unpin,
Self: Unpin,