Attempt at using oyashio

oyashio_playpen.rs

extern crate oyashio;
use oyashio::{Stream};

use std::thread;

fn main() {
    let (mut st, mut sr) = Stream::new();
    let input = vec!["The",
                     "quick",
                     "brown",
                     "fox",
                     "jumped",
                     "over",
                     "the",
                     "lazy",
                     "dog."];

    // Send the lines
    for line in input {
        st.send(line);
    }   

    for i in 0..3 {
        let src = sr.clone();
        thread::spawn(move || {
            for n in src.poll() {
                println!("Thread: {}, \n\t{}", i, n); 
            }   
        }); 
    }   
}