Method join_unwind_mut

datafusion/common-runtime/src/common.rs:87–97

Joins the task using a mutable reference and unwinds the panic if it happens. This method is similar to [`join_unwind`](Self::join_unwind), but takes a mutable reference instead of consuming `self`. This allows the `SpawnedTask` to remain usable after the call. If called multiple times on the same task: - If the task is still running, it will continue waiting for completion - If the task has alr

(&mut self)

    /// - If the task panicked, the first call will resume the panic, and the
    ///   program will not reach subsequent calls
    pub async fn join_unwind_mut(&mut self) -> Result<R, JoinError> {
        self.await.map_err(|e| {
            // `JoinError` can be caused either by panic or cancellation. We have to handle panics:
            if e.is_panic() {
                std::panic::resume_unwind(e.into_panic());
            } else {
                log::warn!("SpawnedTask was polled during shutdown");
                e
            }
        })
    }
}

impl<R> Future for SpawnedTask<R> {