Struct ConnectionStream 

pub struct ConnectionStream { /* private fields */ }

Unified stream type that can represent different connection types.

The stream also owns pending backend input that was already consumed from the socket but belongs to the next NNTP response.

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 compressed_plain(stream: TcpStream) -> Self

Create a compressed plain TCP connection stream

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

Create a compressed TLS connection stream

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

Returns the connection type as a string for logging/debugging

pub const fn is_encrypted(&self) -> bool

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

pub const fn is_unencrypted(&self) -> bool

Returns true if this connection is unencrypted (plain TCP)

pub const fn is_compressed(&self) -> bool

Returns true if this connection uses wire compression

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

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

Returns None for TLS or compressed streams. Useful for socket optimization that requires direct TCP access.

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

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

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

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

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

Get a mutable reference to the TLS stream (if uncompressed 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. For compressed streams, returns the TCP stream from within the wrapper.

pub fn queue_pending_bytes(&mut self, bytes: &[u8]) -> Result<()>

Queue bytes that were already read from the backend for the next response read.

pub fn queue_pending_bytes_first(&mut self, bytes: &[u8]) -> Result<()>

Queue bytes ahead of any bytes already retained by this connection.

pub fn has_pending_bytes(&self) -> bool

pub fn pending_bytes_len(&self) -> usize

pub fn clear_pending_bytes(&mut self)

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_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize>>

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.

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.

impl Debug for ConnectionStream

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

Formats the value using the given formatter.