Struct message_io::node::NodeTask

source · [−]

pub struct NodeTask { /* private fields */ }

Expand description

Entity used to ensure the lifetime of NodeListener::for_each_async() call. The node will process events asynchronously while this entity lives. The destruction of this entity will block until the task is finished. If you want to “unblock” the thread that drops this entity call to NodeHandler::stop() before or from another thread.

Implementations

impl NodeTask

pub fn wait(&mut self)

Block the current thread until the task finalizes. Similar to call drop(node_task) but more verbose and without take the ownership. To finalize the task call NodeHandler::stop(). Calling wait() over an already finished task do not block.

Auto Trait Implementations

impl !RefUnwindSafe for NodeTask

impl Send for NodeTask

impl Sync for NodeTask

impl Unpin for NodeTask

impl !UnwindSafe for NodeTask

Blanket Implementations

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

const: unstable · source

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

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

const: unstable · 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.

impl<T> Same<T> for T

type Output = T

Should always be Self

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

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

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

Performs the conversion.

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

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

The type returned in the event of a conversion error.

const: unstable · source

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

Performs the conversion.

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn vzip(self) -> V