Function forward_text_stream 

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

Drain any Stream<Item = String> (e.g. a mapped LLM completion) into emit_token calls.