chrs 0.3.1

CLI ChRIS client
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
39

use crate::files::decoder::MaybeChrisPathHumanCoder;
use std::future::Future;
use tokio::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender};

/// A channel for communicating with [MaybeChrisPathHumanCoder] in async contexts.
pub struct CoderChannel {
    tx_fname: UnboundedSender<String>,
    rx_decoded: UnboundedReceiver<String>,
}

impl CoderChannel {
    pub fn create(coder: MaybeChrisPathHumanCoder) -> (Self, impl Future<Output = ()> + '_) {
        let (tx_fname, rx_fname) = unbounded_channel();
        let (tx_decoded, rx_decoded) = unbounded_channel();
        let decoder_channel = Self {
            tx_fname,
            rx_decoded,
        };
        let decoder_loop = loop_decoder(coder, rx_fname, tx_decoded);
        (decoder_channel, decoder_loop)
    }

    /// Calls [MaybeChrisPathHumanCoder::decode]
    pub async fn decode(&mut self, fname: String) -> String {
        self.tx_fname.send(fname).unwrap();
        self.rx_decoded.recv().await.unwrap()
    }
}

#[allow(clippy::needless_lifetimes)]
async fn loop_decoder<'a>(
    mut coder: MaybeChrisPathHumanCoder<'a>,
    mut rx: UnboundedReceiver<String>,
    tx: UnboundedSender<String>,
) {
    while let Some(fname) = rx.recv().await {
        tx.send(coder.decode(&fname).await).unwrap()
    }
}