Struct RwRuntime 

pub struct RwRuntime<S, M> {
    pub state: Arc<RwLock<S>>,
    pub bus: Bus<M>,
    pub env: Environment,
    /* private fields */
}

Live runtime with RwLock state — many concurrent readers, exclusive writer on reducer thread.

Fields

state: Arc<RwLock<S>>

bus: Bus<M>

env: Environment

Implementations

impl<S, M> RwRuntime<S, M>

where S: Send + Sync + 'static, M: Send + 'static,

pub fn from_program( program: Program<S, M>, env: Environment, config: RuntimeConfig, ) -> Self

pub fn from_reducer_program<R>( program: ReducerProgram<R>, env: Environment, config: RuntimeConfig, ) -> Self

where R: Reducer<State = S, Action = M> + Send + Sync + 'static,

pub fn rw_store(&self) -> RwStore<S, M>

where S: Clone + Send + Sync + 'static,

pub fn dispatch(&self, msg: M)

pub fn sender(&self) -> BusSender<M>

pub fn cancel(&self, id: EffectId)

pub fn shutdown(self)