Function collect_text 

pub async fn collect_text<T>(
    task: Arc<T>,
    context: Context,
    buffer: usize,
) -> Result<String>
where
    T: Task + Send + Sync + 'static,

Run a Task and join its streamed StreamEvent::Token deltas into one String.