Struct GanglionInprocess 

pub struct GanglionInprocess { /* private fields */ }

Implementations

impl GanglionInprocess

pub fn new() -> Self

pub fn new_shared() -> Arc<Mutex<Self>>

Helper to create an Arc<Mutex>

pub fn new_with_filters( relevant_neurons: HashSet<String>, ignored_neurons: HashSet<String>, ) -> Self

pub fn create_synapse<T, C>( 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>>, ) -> SynapseInprocess<T, C>

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

Trait Implementations

impl Default for GanglionInprocess

fn default() -> Self

Returns the “default value” for a type.

impl Ganglion for GanglionInprocess

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

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

fn adapt<T, C>( &mut self, neuron: Arc<dyn Neuron<T, C> + Send + Sync>, ) -> Pin<Box<dyn Future<Output = Result<(), GanglionError>> + Send + 'static>>

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

impl GanglionInternal for GanglionInprocess

fn transmit( &mut self, payload: Arc<dyn PayloadErased + Send + Sync + 'static>, ) -> Pin<Box<dyn Future<Output = Result<Vec<()>, GanglionError>> + Send + 'static>>

fn react( &mut self, neuron_name: String, reactants: Vec<Arc<dyn ReactantErased + Send + Sync + 'static>>, error_reactants: Vec<Arc<dyn ErrorReactantErased + Send + Sync>>, ) -> Pin<Box<dyn Future<Output = Result<(), GanglionError>> + Send + 'static>>

fn unique_id(&self) -> Uuid