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

use kcl::reader::InputReader;
use std::collections::VecDeque;

#[derive(Default)]
pub struct MockReader {
    lines: VecDeque<String>,
}

impl MockReader {
    pub fn with_input(input: String) -> Self {
        let mut reader = Self::default();
        reader.add_input(input);

        reader
    }

    pub fn add_input(&mut self, input: String) {
        self.lines.push_back(input)
    }
}

impl InputReader for MockReader {
    fn next(&mut self) -> eyre::Result<String> {
        self.lines
            .pop_front()
            .ok_or(eyre::eyre!("no input to read"))
    }
}