spawn.rs

    if input.is_some() {
        let tx = tx.clone();
        let mut input = BufReader::new(input.unwrap());
        ::std::thread::spawn(
            move || {
                let mut buf = String::new();
                // TODO read_until pegs CPU at 100% without a sleep there
                while let Ok(len) = ::std::io::BufRead::read_line(&mut input, &mut buf) {
                    if len == 0 {
                        break;
                    }

                    let _ = tx.send(RagerEvent::Line(buf.as_bytes().to_owned()));
                    buf.clear();
                }

                let _ = tx.send(RagerEvent::EndInput);
            }
        );
    }