diff options
author | Alex Auvolat <alex@adnab.me> | 2022-06-29 12:52:58 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2022-06-29 12:52:58 +0200 |
commit | 3cf91429c7eb675639fbcbf006e04d790645cf77 (patch) | |
tree | fcf9590a98955063a63c5fcc58f4ae9764da1a28 /src/lmtp.rs | |
parent | 90b143e1c57c6561998176878b2cc586b2d89c80 (diff) | |
download | aerogramme-3cf91429c7eb675639fbcbf006e04d790645cf77.tar.gz aerogramme-3cf91429c7eb675639fbcbf006e04d790645cf77.zip |
Clean up unused imports
Diffstat (limited to 'src/lmtp.rs')
-rw-r--r-- | src/lmtp.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/lmtp.rs b/src/lmtp.rs index 29d61af..9036874 100644 --- a/src/lmtp.rs +++ b/src/lmtp.rs @@ -2,20 +2,20 @@ use std::collections::HashMap; use std::net::SocketAddr; use std::{pin::Pin, sync::Arc}; -use anyhow::{bail, Result}; +use anyhow::{Result}; use async_trait::async_trait; use duplexify::Duplex; use futures::{io, AsyncRead, AsyncReadExt, AsyncWrite}; use futures::{stream, stream::FuturesUnordered, StreamExt}; use log::*; -use rusoto_s3::{PutObjectRequest, S3Client, S3}; -use tokio::net::{TcpListener, TcpStream}; +use rusoto_s3::{PutObjectRequest, S3}; +use tokio::net::{TcpListener}; use tokio::select; use tokio::sync::watch; use tokio_util::compat::*; use smtp_message::{Email, EscapedDataReader, Reply, ReplyCode}; -use smtp_server::{reply, Config, ConnectionMetadata, Decision, MailMetadata, Protocol}; +use smtp_server::{reply, Config, ConnectionMetadata, Decision, MailMetadata}; use crate::config::*; use crate::cryptoblob::*; @@ -120,7 +120,7 @@ impl Config for LmtpServer { async fn filter_from( &self, from: Option<Email>, - meta: &mut MailMetadata<Message>, + _meta: &mut MailMetadata<Message>, _conn_meta: &mut ConnectionMetadata<Conn>, ) -> Decision<Option<Email>> { Decision::Accept { @@ -161,7 +161,7 @@ impl Config for LmtpServer { &'resp self, reader: &mut EscapedDataReader<'_, R>, meta: MailMetadata<Message>, - conn_meta: &'resp mut ConnectionMetadata<Conn>, + _conn_meta: &'resp mut ConnectionMetadata<Conn>, ) -> Pin<Box<dyn futures::Stream<Item = Decision<()>> + Send + 'resp>> where R: Send + Unpin + AsyncRead, |