Trait Reactant 

pub trait Reactant<T, C>
where
    C: Codec<T> + CodecName + Send + Sync + 'static,
    T: Send + Sync + 'static,
    Self: Send + Sync,
{
    // Required methods
    fn react(
        &self,
        payload: Arc<Payload<T, C>>,
    ) -> Pin<Box<dyn Future<Output = Result<(), ReactantError>> + Send + 'static>>;
    fn erase(self: Box<Self>) -> Arc<dyn ReactantErased + Send + Sync + 'static>;

    // Provided method
    fn new_erased(self) -> Arc<dyn ReactantErased + Send + Sync + 'static>
       where Self: Sized + 'static { ... }
}

Required Methods

fn react( &self, payload: Arc<Payload<T, C>>, ) -> Pin<Box<dyn Future<Output = Result<(), ReactantError>> + Send + 'static>>

fn erase(self: Box<Self>) -> Arc<dyn ReactantErased + Send + Sync + 'static>

Provided Methods

fn new_erased(self) -> Arc<dyn ReactantErased + Send + Sync + 'static>

where Self: Sized + 'static,

Helper to consume this reactant and return an erased Arc.

Implementors

impl<T, C> Reactant<T, C> for PlexusExternalInternalReactant<T, C>

where C: Codec<T> + CodecName + Send + Sync + 'static, T: Send + Sync + 'static,

impl<T, C> Reactant<T, C> for PlexusInternalReactant<T, C>

where C: Codec<T> + CodecName + Send + Sync + 'static, T: Send + Sync + 'static,