Function plumbum::consume

pub fn consume<'a, I, O>() -> ConduitM<'a, I, O, Option<I>>

Wait for a single input value from upstream.

If no data is available, returns None. Once it returns None, subsequent calls will also return None.