use std::io;
use std::pin::Pin;
use std::task::{Context, Poll};
use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
use tokio::net::TcpStream;
#[cfg(unix)]
use tokio::net::UnixStream;
#[derive(Debug)]
enum Inner {
Tcp(TcpStream),
#[cfg(unix)]
Unix(UnixStream),
}
#[derive(Debug)]
pub struct Socket(Inner);
impl Socket {
pub(crate) fn new_tcp(stream: TcpStream) -> Socket {
Socket(Inner::Tcp(stream))
}
#[cfg(unix)]
pub(crate) fn new_unix(stream: UnixStream) -> Socket {
Socket(Inner::Unix(stream))
}
}
impl AsyncRead for Socket {
fn poll_read(
mut self: Pin<&mut Self>,
cx: &mut Context<'_>,
buf: &mut ReadBuf<'_>,
) -> Poll<io::Result<()>> {
match &mut self.0 {
Inner::Tcp(s) => Pin::new(s).poll_read(cx, buf),
#[cfg(unix)]
Inner::Unix(s) => Pin::new(s).poll_read(cx, buf),
}
}
}
impl AsyncWrite for Socket {
fn poll_write(
mut self: Pin<&mut Self>,
cx: &mut Context<'_>,
buf: &[u8],
) -> Poll<io::Result<usize>> {
match &mut self.0 {
Inner::Tcp(s) => Pin::new(s).poll_write(cx, buf),
#[cfg(unix)]
Inner::Unix(s) => Pin::new(s).poll_write(cx, buf),
}
}
fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
match &mut self.0 {
Inner::Tcp(s) => Pin::new(s).poll_flush(cx),
#[cfg(unix)]
Inner::Unix(s) => Pin::new(s).poll_flush(cx),
}
}
fn poll_shutdown(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
match &mut self.0 {
Inner::Tcp(s) => Pin::new(s).poll_shutdown(cx),
#[cfg(unix)]
Inner::Unix(s) => Pin::new(s).poll_shutdown(cx),
}
}
}