Function stream_local 

pub fn stream_local<T, E, S>(make: impl Fn() -> S + 'static) -> Operator<T>
where
    T: 'static,
    E: Error + 'static,
    S: Stream<Item = Result<T, E>> + 'static,

stream_local: pump a fresh single-thread local fallible stream through the graph-local driver. Every Ok(item) becomes DATA; stream exhaustion emits COMPLETE; the first Err(error) emits ERROR and terminates the source.