noem 0.1.0

Resend mail fetched by different strategies to different places
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use crate::{adapter::Adapter, fetcher::Fetcher, resender::Resender};
use futures::StreamExt;

pub struct Manager<F, R, A>
where
    F: Fetcher,
    R: Resender,
    A: Adapter<Input = F::Output, Output = R::Input>,
{
    fetcher: F,
    resender: R,
    adapter: A,
}
impl<F, R, A> Manager<F, R, A>
where
    F: Fetcher,
    R: Resender,
    A: Adapter<Input = F::Output, Output = R::Input>,
{
    pub fn new(fetcher: F, resender: R, adapter: A) -> Self {
        Self {
            fetcher,
            resender,
            adapter,
        }
    }

    pub async fn run(&self) -> Result<(), F::Error> {
        let mut fetcher = Box::pin(self.fetcher.fetch().await?);

        while let Some(Ok(Some(message))) = fetcher.next().await {
            if let Ok(output) = self.adapter.convert(message) {
                self.resender.send(output).await.ok();
            }
        }
        Ok(())
    }
}