Function forward_text_stream 

pub async fn forward_text_stream<S>(task_id: impl Into<String>, stream: S)
where
    S: Stream<Item = String> + Unpin,