new-home-application 0.1.3

New Home iot application framework. Meant to build application for the New Home Core
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

use std::io::{BufRead, BufReader, Error};
use std::net::TcpStream;

/// Implements the `TcpReader` with a `BufReader` which is wrapping around a `std::net::TcpStream`
pub struct TcpReaderImpl {
    /// The reader which is called when the `read_line` method is called
    /// Is supplied in the constructor as already created `BufReader`
    reader: BufReader<TcpStream>
}

/// The `TcpReader` trait is meant to abstract some kind of a stream reader
/// This is useful in unit tests where a reader type is required
pub trait TcpReader {
    /// Reads a line from the connected `std::net::BufReader`
    /// Returns the read line
    fn read_line(&mut self) -> Result<String, Error>;
}

impl TcpReader for TcpReaderImpl {
    fn read_line(&mut self) -> Result<String, Error> {
        let mut buf = String::new();
        self.reader.read_line(&mut buf)?;

        Ok(buf)
    }
}

impl TcpReaderImpl {
    pub fn new(reader: BufReader<TcpStream>) -> Self {
        Self {
            reader
        }
    }
}