Struct Pee 

#[non_exhaustive]
pub struct Pee { /* private fields */ }

Runtime engine for one pee invocation. Constructed via PeeBuilder.

Examples

let mut pee = PeeBuilder::new().build()?;
let input = Cursor::new(b"hello".to_vec());
pee.run(input)?;

Implementations

impl Pee

pub fn run<R: Read>(&mut self, reader: R) -> Result<(), Error>

Read from reader and fan out each chunk to every registered sink in registration order. On sink BrokenPipe, the sink is dropped from the live-set and the fan-out continues to the remaining sinks (FR-003 + FR-036).

Writer-untouched invariant (FR-022): every other live sink receives the COMPLETE current chunk in registration order before the failing sink is dropped.

Zero-sink case (FR-006): drains the reader to completion and returns Ok.

Trait Implementations

impl Debug for Pee

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.