Trait overclock::core::Route

pub trait Route<M>: Send + Sync + DynClone {
    fn try_send_msg<'life0, 'async_trait>(
        &'life0 self, 
        message: M
    ) -> Pin<Box<dyn Future<Output = Result<Option<M>>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn send_msg<'life0, 'async_trait>(
        &'life0 self, 
        message: M
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}

Dynamic route as trait object, should be implemented on the actor’s handle

Required Methods

fn try_send_msg<'life0, 'async_trait>(
    &'life0 self,
    message: M
) -> Pin<Box<dyn Future<Output = Result<Option<M>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Try to send message to the channel.

fn send_msg<'life0, 'async_trait>(
    &'life0 self,
    message: M
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

if the Route is behind lock, drop the lock before invoking this method.

Trait Implementations

impl<'clone, M> Clone for Box<dyn Route<M> + 'clone>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'clone, M> Clone for Box<dyn Route<M> + Send + 'clone>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'clone, M> Clone for Box<dyn Route<M> + Sync + 'clone>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'clone, M> Clone for Box<dyn Route<M> + Send + Sync + 'clone>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

Implementors

impl<M: 'static + Send, E: Send> Route<M> for AbortableBoundedHandle<E> where
    E: TryFrom<M>,
    E::Error: Send, 

impl<M: 'static + Send, E: Send> Route<M> for AbortableUnboundedHandle<E> where
    E: TryFrom<M>, 

impl<M: 'static + Send, E: Send> Route<M> for BoundedHandle<E> where
    E: TryFrom<M>,
    E::Error: Send, 

impl<M: 'static + Send, E: Send> Route<M> for UnboundedHandle<E> where
    E: TryFrom<M>,