Struct SynapseInprocess 

pub struct SynapseInprocess<T, C>
where
    C: Codec<T> + CodecName + Send + Sync + 'static,
    T: Sync + Send + 'static,
{ /* private fields */ }

Implementations

impl<T, C> SynapseInprocess<T, C>

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

pub fn new( neuron: Arc<dyn Neuron<T, C> + Send + Sync>, reactants: Vec<Arc<dyn Reactant<T, C> + Send + Sync>>, error_reactants: Vec<Arc<dyn ErrorReactant<T, C> + Send + Sync>>, ) -> Self

pub fn from_erased( neuron: Arc<dyn NeuronErased + Send + Sync + 'static>, reactants: Vec<Arc<dyn ReactantErased + Send + Sync + 'static>>, ) -> Option<Self>

where T: 'static, C: 'static,

Create a new SynapseInprocess from type-erased neuron and reactants Returns None if the types don’t match

Trait Implementations

impl<T, C> SynapseInternal<T, C> for SynapseInprocess<T, C>

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

fn neuron(&self) -> Arc<dyn Neuron<T, C> + Send + Sync>

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

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

fn react( &mut self, reactants: Vec<Arc<dyn Reactant<T, C> + Send + Sync>>, error_reactants: Vec<Arc<dyn ErrorReactant<T, C> + Send + Sync>>, ) -> Result<(), SynapseError>