示例

extern crate futures;
extern crate tokio;
extern crate new_tokio_smtp;
#[macro_use]
extern crate vec1;
extern crate rpassword;

use std::io::{stdin, stdout, Write};

use futures::stream::Stream;
use futures::future::lazy;
use new_tokio_smtp::error::GeneralError;
use new_tokio_smtp::{command, Connection, ConnectionConfig, Domain};
use new_tokio_smtp::send_mail::{
    Mail, EncodingRequirement,
    MailAddress, MailEnvelop,
};

struct Request {
    config: ConnectionConfig<command::auth::Plain>,
    mails: Vec<MailEnvelop>
}

fn main() {
    let Request { config, mails } = read_request();
    // We only have iter map overhead because we
    // don't have a failable mail encoding step, which normally is required.
    let mails = mails.into_iter().map(|m| -> Result<_, GeneralError> { Ok(m) });

    println!("[now starting tokio]");
    tokio::run(lazy(move || {
        println!("[start connect_send_quit]");
        Connection::connect_send_quit(config, mails)
            //Stream::for_each is design wise broken in futures v0.1
            .then(|result| Ok(result))
            .for_each(|result| {
                if let Err(err) = result {
                    println!("[sending mail failed]: {}", err);
                } else {
                    println!("[successfully send mail]")
                }
                Ok(())
            })
    }))
}


fn read_request() -> Request {

    println!("preparing to send mail with ethereal.email");
    let sender = read_email();
    let passwd = read_password();

    // The `from_unchecked` will turn into a `.parse()` in the future.
    let config = ConnectionConfig
        ::builder(Domain::from_unchecked("smtp.ethereal.email"))
            .expect("resolving domain failed")
        .auth(command::auth::Plain::from_username(sender.clone(), passwd)
            .expect("username/password can not contain \\0 bytes"))
        .build();

    // the from_unchecked normally can be used if we know the address is valid
    // a mail address parser will be added at some point in the future
    let send_to = MailAddress::from_unchecked("[email protected]");

    // using string fmt to crate mails IS A
    // REALLY BAD IDEA there are a ton of ways
    // this can go wrong, so don't do this in
    // practice, use some library to crate mails
    let raw_mail = format!(concat!(
        "Date: Thu, 14 Jun 2018 11:22:18 +0000\r\n",
        "From: You <{}>\r\n",
        //ethereal doesn't delivers any mail so it's fine
        "To: Invalid <{}>\r\n",
        "Subject: I am spam?\r\n",
        "\r\n",
        "...\r\n"
    ), sender.as_str(), send_to.as_str());

    // this normally adapts to a higher level abstraction
    // of mail then this crate provides
    let mail_data = Mail::new(EncodingRequirement::None, raw_mail.to_owned());

    let mail = MailEnvelop::new(sender, vec1![ send_to ], mail_data);

    Request {
        config,
        mails: vec![ mail ]
    }
}

fn read_email() -> MailAddress {
    let stdout = stdout();
    let mut handle = stdout.lock();
    write!(handle, "enter ethereal.email mail address\n[Note mail is not validated in this example]: ")
        .unwrap();
    handle.flush().unwrap();

    let mut line = String::new();
    stdin().read_line(&mut line).unwrap();
    MailAddress::from_unchecked(line.trim())
}

fn read_password() -> String {
    rpassword::prompt_password_stdout("password: ").unwrap()
}

测试

cargo测试 --功能 "模拟实现"

现在仅运行cargo test不起作用，这可能在将来通过cargo支持“仅测试默认功能”或类似的功能得到修复。

调试SMTP

如果启用了日志（默认）功能，并将日志级别设置为跟踪，则记录整个客户端/服务器交互。

服务器发送的任何行在接收后并解析前都会被记录，客户端发送的任何行在发送前都会被记录（在刷新前）。

例外情况是发送邮件正文不会记录。此外，对于客户端发送的任何以“AUTH”开头的行，除了下一个单词之外的所有内容都将被红字覆盖，以防止记录密码、访问令牌等。例如，在auth plain登录的情况下，只有"AUTH PLAIN <redacted>"会被记录。

这意味着在使用跟踪日志时，以下内容仍将被记录

• 客户端ID
• 服务器ID
• 服务器问候消息（可能包含连接到的服务器的客户端IP或DNS名称，取决于您连接到的服务器）。
• 发送的邮件地址
• 所有接收的邮件地址

鉴于跟踪日志仅应启用用于调试目的，因此即使与GDPR不兼容也不会有问题。如果您仍然设置它，使其不适用于此crate。例如，使用env_logger，它可能类似于`RUST_LOG="new_tokio_smtp=warn,trace"`以启用除smtp之外的所有位置的跟踪日志。但您可能会遇到GDPR不兼容性，因为这可能会记录例如连接客户端的IP地址等。

请注意，跟踪日志确实意味着在写入日志之外还有性能开销，因为跟踪日志是在低级别上完成的，其中不是字符串而是字节被处理，因此它们必须在每个命令行（不是邮件消息）发送之前被转换回字符串，并且客户端发送的每个命令行都需要检查是否以AUTH开头，并需要进行红字覆盖等。

概念

库背后的概念在notes/concept.md文件中进行了说明。

可用性助手

该库提供了一些可用性助手

1. chain::chain提供了一种简单的方法来链式调用多个SMTP命令，当链中的前一个命令未以任何方式失败时，将发送每个命令。

2. mock_support功能：扩展Socket抽象，不仅抽象了Socket是TcpStream或TlsStream，而且还添加了一个新的变体，即boxed MockStream，这使得smtp库，以及在其之上构建的库更容易进行测试。

3. mock::MockStream（使用mock-impl功能）这是一个简单的MockStream实现，允许您测试发送给它哪些数据，并为其模拟响应。（尽管它目前仅限于一个固定的预定义对话，如果需要更多，必须使用自定义的MockStream实现）

4. future_ext::ResultWithContextExt：提供ctx_and_then和ctx_or_else方法，这使得处理将结果解析为项到（此处为连接）的上下文字元和属于不同抽象级别的Result（此处为可能的CommandError，而未来的Error是一个连接错误，例如破损的管道）变得更容易。