Enum DualStream 

pub enum DualStream {
    Tcp(TcpStream),
    Uds(UnixStream),
}

A stream that can be either a TCP stream or a Unix Domain Socket stream.

This enum provides a unified interface for both TCP and UDS connections, implementing the necessary async I/O traits to work seamlessly with Axum and other async frameworks.

Examples

use axum_listener::listener::DualListener;

let listener = DualListener::bind("localhost:8080").await.unwrap();
let (stream, _addr) = listener.accept().await.unwrap();

// The stream can be used with Axum or any other async framework
// that works with tokio's AsyncRead + AsyncWrite traits
println!("Accepted connection from: {:?}", _addr);

Variants

Tcp(TcpStream)

A TCP stream for network connections

Uds(UnixStream)

A Unix Domain Socket stream for local inter-process communication

Trait Implementations

impl AsyncRead for DualStream

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for DualStream

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl From<TcpStream> for DualStream

fn from(stream: TcpStream) -> Self

Converts to this type from the input type.

impl From<UnixStream> for DualStream

Available on Unix only.

fn from(stream: UnixStream) -> Self

Converts to this type from the input type.