Struct Reader 

pub struct Reader<R> { /* private fields */ }

Implementations

impl<R> Reader<R>

where R: Read,

pub fn new(r: R) -> Self

where R: Read,

Examples found in repository

examples/port.rs (line 20)

fn main() {
    let (sender, receiver) = mpsc::channel::<Vec<u8>>();

    // port -> beam
    let mut writer = ei::Writer::new(io::stdout());

    thread::spawn(move || {
        while let Ok(vec) = receiver.recv() {
            writer.send(vec.as_slice()).unwrap()
        }
    });

    // beam -> port
    let mut reader = ei::Reader::new(io::stdin());

    while let Ok(vec) = reader.recv() {
        let s = sender.clone();
        thread::spawn(move || {
            let req: (u8, i64, i64, ei::Pid, ei::Atom, ei::Ref) =
                ei::deserialize!(vec.as_slice()).unwrap();

            let res = match req.0 {
                0x61 => {
                    let res = (ei::atom!("ok"), add(req.1, req.2), req.3, req.4, req.5);
                    ei::serialize!(&res).unwrap()
                }
                0x73 => {
                    let res = (ei::atom!("ok"), sub(req.1, req.2), req.3, req.4, req.5);
                    ei::serialize!(&res).unwrap()
                }
                _ => {
                    let res = (ei::atom!("error"), ei::atom!("undef"), req.3, req.4, req.5);
                    ei::serialize!(&res).unwrap()
                }
            };

            s.send(res).unwrap();
        });
    }
}

pub fn read_exact_u8(&mut self) -> Result<Vec<u8>, Error>

pub fn read_exact_u16(&mut self) -> Result<Vec<u8>, Error>

pub fn read_exact_u32(&mut self) -> Result<Vec<u8>, Error>

pub fn read_exact_usize(&mut self, len: usize) -> Result<Vec<u8>, Error>

pub fn read_string_u8(&mut self) -> Result<String, Error>

pub fn read_string_u16(&mut self) -> Result<String, Error>

pub fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>

pub fn read_i16(&mut self) -> Result<i16, Error>

pub fn read_i32(&mut self) -> Result<i32, Error>

pub fn read_u8(&mut self) -> Result<u8, Error>

pub fn read_u16(&mut self) -> Result<u16, Error>

pub fn read_u32(&mut self) -> Result<u32, Error>

pub fn read_u64(&mut self) -> Result<u64, Error>

pub fn read_f64(&mut self) -> Result<f64, Error>

impl<R> Reader<R>

where R: Read,

pub fn recv(&mut self) -> Result<Vec<u8>, Error>

Examples found in repository

examples/port.rs (line 22)

fn main() {
    let (sender, receiver) = mpsc::channel::<Vec<u8>>();

    // port -> beam
    let mut writer = ei::Writer::new(io::stdout());

    thread::spawn(move || {
        while let Ok(vec) = receiver.recv() {
            writer.send(vec.as_slice()).unwrap()
        }
    });

    // beam -> port
    let mut reader = ei::Reader::new(io::stdin());

    while let Ok(vec) = reader.recv() {
        let s = sender.clone();
        thread::spawn(move || {
            let req: (u8, i64, i64, ei::Pid, ei::Atom, ei::Ref) =
                ei::deserialize!(vec.as_slice()).unwrap();

            let res = match req.0 {
                0x61 => {
                    let res = (ei::atom!("ok"), add(req.1, req.2), req.3, req.4, req.5);
                    ei::serialize!(&res).unwrap()
                }
                0x73 => {
                    let res = (ei::atom!("ok"), sub(req.1, req.2), req.3, req.4, req.5);
                    ei::serialize!(&res).unwrap()
                }
                _ => {
                    let res = (ei::atom!("error"), ei::atom!("undef"), req.3, req.4, req.5);
                    ei::serialize!(&res).unwrap()
                }
            };

            s.send(res).unwrap();
        });
    }
}