Struct datafusion_common_runtime::common::SpawnedTask

pub struct SpawnedTask<R> { /* private fields */ }

Helper that provides a simple API to spawn a single task and join it. Provides guarantees of aborting on Drop to keep it cancel-safe.

Technically, it’s just a wrapper of JoinSet (with size=1).

Implementations

impl<R: 'static> SpawnedTask<R>

pub fn spawn<T>(task: T) -> Self

where T: Future<Output = R> + Send + 'static, R: Send,

pub fn spawn_blocking<T>(task: T) -> Self

where T: FnOnce() -> R + Send + 'static, R: Send,

pub async fn join(self) -> Result<R, JoinError>

Joins the task, returning the result of join (Result<R, JoinError>).

pub async fn join_unwind(self) -> R

Joins the task and unwinds the panic if it happens.

Trait Implementations

impl<R: Debug> Debug for SpawnedTask<R>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.