kcl 0.3.3

a Rust interface to the Amazon Kinesis Client Library (KCL) MultiLangDaemon
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

use std::io;
use std::io::{Stdout, Write};

use crate::responses::StatusResponse;
use eyre::Result;

pub(crate) fn write_status(writer: &mut impl OutputWriter, message: StatusResponse) -> Result<()> {
    let mut payload = serde_json::to_vec(&message)?;
    payload.push(b'\n');
    writer.write(payload.as_slice())?;

    Ok(())
}

pub trait OutputWriter {
    fn write(&mut self, payload: &[u8]) -> Result<()>;
}

pub struct StdoutWriter {
    out: Stdout,
}

impl StdoutWriter {
    pub(crate) fn new() -> Self {
        Self { out: io::stdout() }
    }
}

impl OutputWriter for StdoutWriter {
    fn write(&mut self, payload: &[u8]) -> Result<()> {
        self.out.write_all(payload)?;
        self.out.flush()?;

        Ok(())
    }
}