Struct StreamTap 

pub struct StreamTap { /* private fields */ }

What a unary consumer, the record, or a layer’s verdict takes from a stream: its outcome, the response the stream ends with or the first error item. The origin folded the response; the tap only watches for it.

Implementations

impl StreamTap

pub fn new() -> Self

A new stream tap.

pub fn observe( &mut self, item: &Result<Relayed, ErrorReport>, ) -> Option<Result<Outcome, ErrorReport>>

Returns the stream’s outcome once: the response it ends with, or the first error item. Every later call returns None.

Trait Implementations

impl Default for StreamTap

fn default() -> Self

Returns the “default value” for a type.