Thoughtful products that work

1use tokio::sync::mpsc;
2use tracing::{info, instrument};
3 
4pub struct Pipeline<T: Send> {
5    tx: mpsc::Sender<T>,
6    rx: mpsc::Receiver<T>,
7}
8 
9impl<T: Send + 'static> Pipeline<T> {
10    #[instrument(skip(self))]
11    pub async fn run(self) -> Result<()> {
12        info!("pipeline.start");
13        while let Some(msg) = self.rx.recv().await {
14            self.process(msg).await?;
15        }
16        Ok(())
17    }
18}