Struct SmtpClient

pub struct SmtpClient<T: AsyncRead + AsyncWrite> {
    pub stream: T,
    pub timeout: Duration,
}

SMTP client builder

Fields

stream: T

timeout: Duration

Implementations

impl<T: AsyncRead + AsyncWrite + Unpin> SmtpClient<T>

pub async fn authenticate<U>( &mut self, credentials: impl AsRef<Credentials<U>>, capabilities: impl AsRef<EhloResponse<String>>, ) -> Result<&mut Self>

where U: AsRef<str> + PartialEq + Eq + Hash,

impl<T: AsyncRead + AsyncWrite + Unpin> SmtpClient<T>

pub async fn capabilities( &mut self, local_host: &str, is_lmtp: bool, ) -> Result<EhloResponse<String>>

impl<T: AsyncRead + AsyncWrite + Unpin> SmtpClient<T>

pub async fn read(&mut self) -> Result<Response<String>>

pub async fn read_many(&mut self, num: usize) -> Result<Vec<Response<String>>>

pub async fn cmd(&mut self, cmd: impl AsRef<[u8]>) -> Result<Response<String>>

Sends a command to the SMTP server and waits for a reply.

pub async fn cmds( &mut self, cmds: impl IntoIterator<Item = impl AsRef<[u8]>>, ) -> Result<Vec<Response<String>>>

Pipelines multiple command to the SMTP server and waits for a reply.

impl SmtpClient<TcpStream>

pub async fn connect(remote_addr: SocketAddr, timeout: Duration) -> Result<Self>

Connects to a remote host address

pub async fn connect_using( local_ip: IpAddr, remote_addr: SocketAddr, timeout: Duration, ) -> Result<Self>

Connects to a remote host address using the provided local IP

impl<T: AsyncRead + AsyncWrite + Unpin> SmtpClient<T>

pub async fn ehlo(&mut self, hostname: &str) -> Result<EhloResponse<String>>

Sends a EHLO command to the server.

pub async fn lhlo(&mut self, hostname: &str) -> Result<EhloResponse<String>>

Sends a LHLO command to the server.

pub async fn read_ehlo(&mut self) -> Result<EhloResponse<String>>

impl<T: AsyncRead + AsyncWrite + Unpin> SmtpClient<T>

pub async fn mail_from( &mut self, addr: &str, params: &Parameters<'_>, ) -> Result<()>

Sends a MAIL FROM command to the server.

pub async fn rcpt_to( &mut self, addr: &str, params: &Parameters<'_>, ) -> Result<()>

Sends a RCPT TO command to the server.

pub async fn data(&mut self, message: impl AsRef<[u8]>) -> Result<()>

Sends a DATA command to the server.

pub async fn bdat(&mut self, message: impl AsRef<[u8]>) -> Result<()>

Sends a BDAT command to the server.

pub async fn rset(&mut self) -> Result<()>

Sends a RSET command to the server.

pub async fn noop(&mut self) -> Result<()>

Sends a NOOP command to the server.

pub async fn quit(self) -> Result<()>

Sends a QUIT command to the server.

impl<T: AsyncRead + AsyncWrite + Unpin> SmtpClient<T>

pub async fn send<'x>(&mut self, message: impl IntoMessage<'x>) -> Result<()>

Sends a message to the server.

pub async fn send_signed<'x, V: SigningKey>( &mut self, message: impl IntoMessage<'x>, signer: &DkimSigner<V, Done>, ) -> Result<()>

Sends a message to the server.

pub async fn write_message(&mut self, message: &[u8]) -> Result<()>

impl SmtpClient<TcpStream>

pub async fn start_tls( self, tls_connector: &TlsConnector, hostname: &str, ) -> Result<SmtpClient<TlsStream<TcpStream>>>

Upgrade the connection to TLS.

pub async fn into_tls( self, tls_connector: &TlsConnector, hostname: &str, ) -> Result<SmtpClient<TlsStream<TcpStream>>>

impl SmtpClient<TlsStream<TcpStream>>

pub fn tls_connection(&self) -> &ClientConnection