Function ogle::runner::stream_task

pub async fn stream_task<T>(
    cmdline: &str, 
    last_lines: Vec<String>, 
    last_period: Duration, 
    stream: T, 
    pb: &mut Progbar
) -> Result<Vec<String>> where
    T: StreamExt<Item = StreamItem> + Unpin + Send + 'static,