socket.rs

use async_std::io::{self,Read,Write};
use std::mem::MaybeUninit;
use std::pin::Pin;
use std::task::{Context,Poll};
use tokio::io::{AsyncRead,AsyncWrite};

/// A alias for 'static + Unpin + Send + Read + Write
pubtraitAsyncReadWriter:'static + Unpin + Send + Read + Write{}

impl<T>AsyncReadWriterforTwhereT:'static + Unpin + Send + Read + Write{}

/// A adaptor between futures::io::{AsyncRead, AsyncWrite} and tokio::io::{AsyncRead, AsyncWrite}.
pubstructSocket(Box<dynAsyncReadWriter>);

impl<T>From<T>forSocket
where
T:AsyncReadWriter,
{
fnfrom(stream:T) -> Self{
Self(Box::new(stream))
}
}

implAsyncReadforSocket{
#[inline]
unsafefnprepare_uninitialized_buffer(&self,_buf:&mut[MaybeUninit<u8>]) -> bool{
false
}

#[inline]
fnpoll_read(
mutself:Pin<&mutSelf>,
cx:&mutContext<'_>,
buf:&mut[u8],
) -> Poll<io::Result<usize>>{
Pin::new(&mutself.0).poll_read(cx, buf)
}
}

implAsyncWriteforSocket{
#[inline]
fnpoll_write(
mutself:Pin<&mutSelf>,
cx:&mutContext<'_>,
buf:&[u8],
) -> Poll<io::Result<usize>>{
Pin::new(&mutself.0).poll_write(cx, buf)
}

#[inline]
fnpoll_flush(
mutself:Pin<&mutSelf>,
cx:&mutContext<'_>,
) -> Poll<io::Result<()>>{
Pin::new(&mutself.0).poll_flush(cx)
}

#[inline]
fnpoll_shutdown(
mutself:Pin<&mutSelf>,
cx:&mutContext<'_>,
) -> Poll<io::Result<()>>{
Pin::new(&mutself.0).poll_close(cx)
}
}