Struct TlsStream

pub struct TlsStream { /* private fields */ }

An async stream that wraps a rustls connection and a TCP socket.

Implementations

impl TlsStream

pub fn new_client_side( tcp: TcpStream, tls: ClientConnection, buffer_size: Option<NonZero<usize>>, ) -> TlsStream

pub fn new_client_side_from( tcp: TcpStream, connection: ClientConnection, buffer_size: Option<NonZero<usize>>, ) -> TlsStream

pub fn new_server_side( tcp: TcpStream, tls_config: Arc<ServerConfig>, buffer_size: Option<NonZero<usize>>, ) -> TlsStream

pub fn new_server_side_acceptor( tcp: TcpStream, server_config_provider: Arc<dyn Fn(ClientHello<'_>) -> Pin<Box<dyn Future<Output = Result<Arc<ServerConfig>, Error>> + Send>> + Send + Sync>, buffer_size: Option<NonZero<usize>>, ) -> TlsStream

Create a server-side TLS connection that provides the ServerConfig dynamically based on the ClientHello message. This may be used to provide a different server certificate or ALPN configuration depending on the requested hostname.

pub fn new_server_side_from( tcp: TcpStream, connection: ServerConnection, buffer_size: Option<NonZero<usize>>, ) -> TlsStream

pub fn try_into_inner(self) -> Result<(TcpStream, Connection), TlsStream>

Attempt to retrieve the inner stream and connection.

pub fn into_split(self) -> (TlsStreamRead, TlsStreamWrite)

pub async fn into_inner(self) -> Result<(TcpStream, Connection), Error>

pub fn linger(&self) -> Result<Option<Duration>, Error>

pub fn set_linger(&self, dur: Option<Duration>) -> Result<(), Error>

pub fn peer_addr(&self) -> Result<SocketAddr, Error>

Returns the peer address of this socket.

pub fn local_addr(&self) -> Result<SocketAddr, Error>

Returns the local address of this socket.

pub fn poll_handshake( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<TlsHandshake, Error>>

pub async fn handshake(&mut self) -> Result<TlsHandshake, Error>

pub fn try_handshake(&self) -> Result<Option<TlsHandshake>, Error>

Try to get the handshake, if one exists.

pub async fn close(self) -> Result<(), Error>

Trait Implementations

impl AsyncRead for TlsStream

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

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for TlsStream

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

Attempt to write bytes from buf into the object.

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

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

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

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

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

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

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

impl Debug for TlsStream

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

Formats the value using the given formatter.

impl Drop for TlsStream

fn drop(&mut self)

Executes the destructor for this type.