fn spawn_reader_task( stdout: ChildStdout, tee: Option<Arc<dyn Fn(&str) + Send + Sync>>, tx: UnboundedSender<Result<Option<String>, Error>>, )