hypershell-tokio-components 0.1.0

Modular DSL for shellscripting in Rust
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

use core::marker::PhantomData;

use cgp::extra::handler::{Handler, HandlerComponent};
use cgp::prelude::*;
use futures::Stream;
use hypershell_components::dsl::StreamToLines;
use tokio::io::AsyncRead;
use tokio_util::codec::{FramedRead, LinesCodec, LinesCodecError};

#[cgp_new_provider]
impl<Context, Input> Handler<Context, StreamToLines, Input> for HandleStreamToLines
where
    Context: HasAsyncErrorType,
    Input: Send + AsyncRead + Unpin + 'static,
{
    type Output = Box<dyn Stream<Item = Result<String, LinesCodecError>> + Send>;

    async fn handle(
        _context: &Context,
        _tag: PhantomData<StreamToLines>,
        input: Input,
    ) -> Result<Box<dyn Stream<Item = Result<String, LinesCodecError>> + Send>, Context::Error>
    {
        let stream = FramedRead::new(input, LinesCodec::new());

        Ok(Box::new(stream))
    }
}