ringbuf 0.1.2

extern crate ringbuf;

use std::io::{Read};
use std::thread;
use std::time::{Duration};

use ringbuf::{RingBuffer};


fn main() {
    let rb = RingBuffer::<u8>::new(10);
    let (mut prod, mut cons) = rb.split();

    let smsg = "The quick brown fox jumps over the lazy dog";
    
    let pjh = thread::spawn(move || {
        println!("-> sending message: '{}'", smsg);

        let zero = [0 as u8];
        let mut bytes = smsg.as_bytes().chain(&zero[..]);
        loop {
            match prod.read_from(&mut bytes) {
                Ok(n) => {
                    if n == 0 {
                        break;
                    }
                    println!("-> {} bytes sent", n);
                },
                Err(_) => {
                    println!("-> buffer is full, waiting");
                    thread::sleep(Duration::from_millis(1));
                },
            }
        }

        println!("-> message sent");
    });

    let cjh = thread::spawn(move || {
        println!("<- receiving message");

        let mut bytes = Vec::<u8>::new();
        loop {
            match cons.write_into(&mut bytes) {
                Ok(n) => println!("<- {} bytes received", n),
                Err(_) => {
                    if bytes.ends_with(&[0]) {
                        break;
                    } else {
                        println!("<- buffer is empty, waiting");
                        thread::sleep(Duration::from_millis(1));
                    }
                },
            }
        }

        assert_eq!(bytes.pop().unwrap(), 0);
        let msg = String::from_utf8(bytes).unwrap();
        println!("<- message received: '{}'", msg);

        msg
    });

    pjh.join().unwrap();
    let rmsg = cjh.join().unwrap();

    assert_eq!(smsg, rmsg);
}