runnel

runnel is the pluggable io stream. now support: stdio, string io, in memory pipe.

Features

• support common operation: stdin, stdout, stderr, stringin, stringout, pipein and pipeout.
• thin interface
• support testing stream io
• minimum support rustc 1.38.0

Examples

Example of stdio :

rust use runnel::RunnelIoeBuilder; let sioe = RunnelIoeBuilder::new().build();

Example of stringio :

```rust use runnel::RunnelIoeBuilder; use std::io::{BufRead, Write};

let sioe = RunnelIoeBuilder::new() .fillstringiowit_str("ABCDE\nefgh\n") .build();

// pluggable stream in let mut linesiter = sioe.pin().lock().lines().map(|l| l.unwrap()); asserteq!(linesiter.next(), Some(String::from("ABCDE"))); asserteq!(linesiter.next(), Some(String::from("efgh"))); asserteq!(lines_iter.next(), None);

// pluggable stream out

[rustfmt::skip]

let res = sioe.pout().lock() .writefmt(formatargs!("{}\nACBDE\nefgh\n", 1234)); assert!(res.isok()); asserteq!(sioe.pout().lock().buffer_str(), "1234\nACBDE\nefgh\n");

// pluggable stream err

[rustfmt::skip]

let res = sioe.perr().lock() .writefmt(formatargs!("{}\nACBDE\nefgh\n", 1234)); assert!(res.isok()); asserteq!(sioe.perr().lock().buffer_str(), "1234\nACBDE\nefgh\n"); ```

Example of pipeio :

```rust use runnel::RunnelIoeBuilder; use runnel::medium::pipeio::pipe; use std::io::{BufRead, Write};

// create in memory pipe let (aout, ain) = pipe(1);

// a working thread let sioe = RunnelIoeBuilder::new() .fillstringiowitstr("ABCDE\nefgh\n") .pout(aout) // pluggable pipe out .build(); let handler = std::thread::spawn(move || { for line in sioe.pin().lock().lines().map(|l| l.unwrap()) { let mut out = sioe.pout().lock(); out.writefmt(formatargs!("{}\n", line)).unwrap(); out.flush().unwrap(); } });

// a main thread let sioe = RunnelIoeBuilder::new() .fillstringiowitstr("ABCDE\nefgh\n") .pin(ain) // pluggable pipe in .build(); let mut linesiter = sioe.pin().lock().lines().map(|l| l.unwrap()); asserteq!(linesiter.next(), Some(String::from("ABCDE"))); asserteq!(linesiter.next(), Some(String::from("efgh"))); asserteq!(lines_iter.next(), None);

assert!(handler.join().is_ok()); ```