Crate xstream_util

xstream library

Provides [xstream] to take a BufRead and splits it as input among several processes. There’s current not any async support, and therefore no real way to interact with the processes afterwards. Even collecting the output would require effort / synchronization, so currently they’re all just piped to the standard inhereted buffers.

Usage

use std::process::Command;
use xstream_util::Limiting;

let mut input = // ...
// Spawn up to two `cat` processes, could also use `Rotating`
let mut pool = Limiting::new(Command::new("cat"), 2);
xstream_util::xstream(&mut pool, &mut input, &b"\n", &None::<&[u8]>).unwrap();

Structs

• Limiting
  A pool to manage spawning a limited number of processses
• Rotating
  A pool to manage spawning a limited number of processses

Enums

• Error
  An error raised by xstream

Traits

• Pool
  A type that can get child processes on demand

Functions

• xstream
  Stream one reader into several independent processes