Struct tokio::task::join_set::Builder

source ·
pub struct Builder<'a, T> { /* private fields */ }
Available on tokio_unstable and crate feature tracing and crate feature rt only.
Expand description

A variant of task::Builder that spawns tasks on a JoinSet rather than on the current default runtime.

Implementations§

source§

impl<'a, T: 'static> Builder<'a, T>

source

pub fn name(self, name: &'a str) -> Self

Assigns a name to the task which will be spawned.

source

pub fn spawn<F>(self, future: F) -> Result<AbortHandle>where F: Future<Output = T> + Send + 'static, T: Send,

Spawn the provided task with this builder’s settings and store it in the JoinSet, returning an AbortHandle that can be used to remotely cancel the task.

Returns

An AbortHandle that can be used to remotely cancel the task.

Panics

This method panics if called outside of a Tokio runtime.

source

pub fn spawn_on<F>(self, future: F, handle: &Handle) -> Result<AbortHandle>where F: Future<Output = T> + Send + 'static, T: Send,

Spawn the provided task on the provided runtime handle with this builder’s settings, and store it in the JoinSet.

Returns

An AbortHandle that can be used to remotely cancel the task.

source

pub fn spawn_local<F>(self, future: F) -> Result<AbortHandle>where F: Future<Output = T> + 'static,

Spawn the provided task on the current LocalSet with this builder’s settings, and store it in the JoinSet.

Returns

An AbortHandle that can be used to remotely cancel the task.

Panics

This method panics if it is called outside of a LocalSet.

source

pub fn spawn_local_on<F>( self, future: F, local_set: &LocalSet ) -> Result<AbortHandle>where F: Future<Output = T> + 'static,

Spawn the provided task on the provided LocalSet with this builder’s settings, and store it in the JoinSet.

Returns

An AbortHandle that can be used to remotely cancel the task.

Trait Implementations§

source§

impl<'a, T> Debug for Builder<'a, T>

source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<'a, T> !RefUnwindSafe for Builder<'a, T>

§

impl<'a, T> Send for Builder<'a, T>where T: Send,

§

impl<'a, T> Sync for Builder<'a, T>where T: Send,

§

impl<'a, T> Unpin for Builder<'a, T>

§

impl<'a, T> !UnwindSafe for Builder<'a, T>

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more