Function run_stream 

pub fn run_stream<T: Send + 'static, S: Stream<Item = T> + 'static + Send + Unpin>(
    s: S,
) -> Pin<Box<dyn Stream<Item = T>>>