croc-sidecar 0.1.0

A wrapper for the Croc binary
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 tokio::io::{AsyncBufRead, AsyncBufReadExt, BufReader, Lines};

use crate::Result;

use super::CrocEvent;

/// A `croc` parser that can serialize outputs from the provided `reader`.
pub struct CrocParser<R: AsyncBufRead + Unpin> {
    lines: Lines<BufReader<R>>,
}

impl<R: AsyncBufRead + Unpin> CrocParser<R> {
    /// Creates a new croc output parser for the provided reader.
    pub fn new(inner: R) -> Self {
        let reader = BufReader::new(inner);
        let lines = reader.lines();
        Self { lines }
    }

    /// Parses the next event available in the output
    pub async fn parse_next_event(&mut self) -> Result<CrocEvent> {
        if let Some(line) = self.lines.next_line().await? {
            Ok(CrocEvent::Unknown(line))
        } else {
            Ok(CrocEvent::EOF)
        }
    }
}