(
fut: PyObjectRef,
waiter: PyObjectRef,
vm: &VirtualMachine,
)
| 2587 | |
| 2588 | #[pyfunction] |
| 2589 | fn future_discard_from_awaited_by( |
| 2590 | fut: PyObjectRef, |
| 2591 | waiter: PyObjectRef, |
| 2592 | vm: &VirtualMachine, |
| 2593 | ) -> PyResult<()> { |
| 2594 | // Only operate on native Future/Task objects (including subclasses). |
| 2595 | // Non-native objects are silently ignored. |
| 2596 | if let Some(task) = fut.downcast_ref::<PyTask>() { |
| 2597 | return task.base.awaited_by_discard(&waiter, vm); |
| 2598 | } |
| 2599 | if let Some(future) = fut.downcast_ref::<PyFuture>() { |
| 2600 | return future.awaited_by_discard(&waiter, vm); |
| 2601 | } |
| 2602 | Ok(()) |
| 2603 | } |
| 2604 | |
| 2605 | // TaskStepMethWrapper - wrapper for task step callback with proper repr |
| 2606 |
no test coverage detected