SubMain

Struct SubMain 

Source
pub struct SubMain<'m> { /* private fields */ }
Expand description

A sub-main instance, which can be used to contribute global tasks to the main instance which created this sub instance, but gather own tasks, which can be run independently by calling the SubMain::run function.

Implementations§

Source§

impl SubMain<'_>

Source

pub fn is_empty(&self) -> bool

Returns true is there are no tasks scheduled so far.

Source

pub fn sub_main(&self) -> SubMain<'_>

Create a new sub-main instance.

Source

pub fn sub_main_seed(&self) -> SubMainSeed

Create a seed or a sub-main instance, which can be sent.

Source

pub async fn run(self) -> Result<()>

Run the recorded tasks.

NOTE: This does not run any health checks, these must be run by the main instance.

Trait Implementations§

Source§

impl<'m> Extend<Pin<Box<dyn Future<Output = Result<(), Error>> + 'm>>> for SubMain<'m>

Source§

fn extend<T: IntoIterator<Item = LocalBoxFuture<'m, Result<()>>>>( &mut self, iter: T, )

Extends a collection with the contents of an iterator. Read more
Source§

fn extend_one(&mut self, item: A)

🔬This is a nightly-only experimental API. (extend_one)
Extends a collection with exactly one element.
Source§

fn extend_reserve(&mut self, additional: usize)

🔬This is a nightly-only experimental API. (extend_one)
Reserves capacity in a collection for the given number of additional elements. Read more
Source§

impl From<SubMainSeed> for SubMain<'_>

Source§

fn from(seed: SubMainSeed) -> Self

Converts to this type from the input type.
Source§

impl<'m> Spawner for SubMain<'m>

Source§

fn spawn_boxed(&mut self, future: Pin<Box<dyn Future<Output = Result<()>>>>)

Source§

impl<'m> Startup for SubMain<'m>

Source§

fn check_boxed(&mut self, check: Box<dyn HealthChecked>)

Add a health check.
Source§

fn use_tracing(&self) -> bool

Allow the application to check if the runtime wants to enable tracing. Read more
Source§

fn runtime_config(&self) -> &RuntimeConfig

Access the runtime config.

Auto Trait Implementations§

§

impl<'m> Freeze for SubMain<'m>

§

impl<'m> !RefUnwindSafe for SubMain<'m>

§

impl<'m> !Send for SubMain<'m>

§

impl<'m> !Sync for SubMain<'m>

§

impl<'m> Unpin for SubMain<'m>

§

impl<'m> !UnwindSafe for SubMain<'m>

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where 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> FutureExt for T

Source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
Source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
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 T
where 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> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<S> SpawnerExt for S
where S: Spawner + ?Sized,

Source§

fn spawn_iter<I>(&mut self, iter: I)
where I: IntoIterator<Item = Pin<Box<dyn Future<Output = Result<()>>>>>,

Source§

fn spawn<F>(&mut self, f: F)
where F: Future<Output = Result<()>> + 'static,

Source§

impl<S> StartupExt for S
where S: Startup + ?Sized,

Source§

fn check_iter<I>(&mut self, iter: I)
where I: IntoIterator<Item = Box<dyn HealthChecked>>,

Add several health checks at once.
Source§

fn check<C>(&mut self, c: C)
where C: HealthChecked + 'static,

Source§

fn spawn_iter<I>(&mut self, iter: I)
where I: IntoIterator<Item = Pin<Box<dyn Future<Output = Result<()>>>>>,

Source§

fn spawn<F>(&mut self, f: F)
where F: Future<Output = Result<()>> + 'static,

Source§

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

Source§

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 T
where U: TryFrom<T>,

Source§

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<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

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
Source§

impl<T> ErasedDestructor for T
where T: 'static,