Function run_streaming 

pub fn run_streaming<F>(
    buffer: usize,
    fut: F,
) -> (StreamReceiver, JoinHandle<F::Output>)
where
    F: Future + Send + 'static,
    F::Output: Send + 'static,