pub async fn collect_text( stream: Pin<Box<dyn Stream<Item = Result<RunEvent>> + '_>>, ) -> Result<String>