Function get_task_repr_info

crates/stdlib/src/_asyncio.rs:911–939

(task: &PyObject, vm: &VirtualMachine)

    }

    fn get_task_repr_info(task: &PyObject, vm: &VirtualMachine) -> PyResult<Wtf8Buf> {
        // vm.import returns the top-level module, get base_tasks submodule
        match vm
            .import("asyncio.base_tasks", 0)
            .and_then(|asyncio| asyncio.get_attr(vm.ctx.intern_str("base_tasks"), vm))
        {
            Ok(base_tasks) => {
                match vm.get_attribute_opt(base_tasks, vm.ctx.intern_str("_task_repr_info")) {
                    Ok(Some(func)) => {
                        let info: PyObjectRef = func.call((task.to_owned(),), vm)?;
                        let list: PyListRef = info.downcast().map_err(|_| {
                            vm.new_type_error("_task_repr_info should return a list")
                        })?;
                        let mut result = Wtf8Buf::new();
                        let parts = list.borrow_vec();
                        for (i, x) in parts.iter().enumerate() {
                            if i > 0 {
                                result.push_str(" ");
                            }
                            result.push_wtf8(x.str(vm)?.as_wtf8());
                        }
                        Ok(result)
                    }
                    _ => get_future_repr_info(task, vm),
                }
            }
            Err(_) => get_future_repr_info(task, vm),
        }
    }

    #[pyattr]
    #[pyclass(name = "FutureIter", module = "_asyncio", traverse)]