Struct Writer 

pub struct Writer<W> { /* private fields */ }

Implementations

impl<W> Writer<W>

where W: Write,

pub fn new(w: W) -> Self

where W: Write,

Examples found in repository

examples/port.rs (line 11)

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 write_all(&mut self, buf: &[u8]) -> Result<(), Error>

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

pub fn write_i16(&mut self, i: i16) -> Result<(), Error>

pub fn write_i32(&mut self, i: i32) -> Result<(), Error>

pub fn write_u8(&mut self, u: u8) -> Result<(), Error>

pub fn write_u16(&mut self, u: u16) -> Result<(), Error>

pub fn write_u32(&mut self, u: u32) -> Result<(), Error>

pub fn write_u64(&mut self, u: u64) -> Result<(), Error>

pub fn write_f64(&mut self, f: f64) -> Result<(), Error>

impl<W> Writer<W>

where W: Write,

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

Examples found in repository

examples/port.rs (line 15)

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();
        });
    }
}