Enum ConnectionStream 

pub enum ConnectionStream {
    Plain(TcpStream),
    Tls(Box<TlsStream<TcpStream>>),
}

Unified stream type that can represent different connection types

This enum allows the proxy to handle both plain TCP and TLS connections through a single type, avoiding the need for trait objects and their associated heap allocation overhead.

Variants

Plain(TcpStream)

Plain TCP connection

Tls(Box<TlsStream<TcpStream>>)

TLS-encrypted connection

Implementations

impl ConnectionStream

pub fn plain(stream: TcpStream) -> Self

Create a new plain TCP connection stream

pub fn tls(stream: TlsStream<TcpStream>) -> Self

Create a new TLS-encrypted connection stream

pub fn connection_type(&self) -> &'static str

Returns the connection type as a string for logging/debugging

pub fn is_encrypted(&self) -> bool

Returns true if this connection uses encryption (TLS/SSL)

pub fn is_unencrypted(&self) -> bool

Returns true if this connection is unencrypted (plain TCP)

pub fn as_tcp_stream(&self) -> Option<&TcpStream>

Get a reference to the underlying TCP stream (if plain TCP)

Returns None for TLS streams, as the TCP stream is wrapped. Useful for socket optimization that requires direct TCP access.

pub fn as_tcp_stream_mut(&mut self) -> Option<&mut TcpStream>

Get a mutable reference to the underlying TCP stream (if plain TCP)

pub fn as_tls_stream(&self) -> Option<&TlsStream<TcpStream>>

Get a reference to the TLS stream (if TLS connection)

pub fn as_tls_stream_mut(&mut self) -> Option<&mut TlsStream<TcpStream>>

Get a mutable reference to the TLS stream (if TLS connection)

pub fn underlying_tcp_stream(&self) -> &TcpStream

Get the underlying TCP stream reference regardless of connection type

For plain TCP, returns the stream directly. For TLS, returns the underlying TCP stream within the TLS wrapper.

Trait Implementations

impl AsyncRead for ConnectionStream

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 ConnectionStream

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 Debug for ConnectionStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.