Struct SharedMovingAverageStore 

pub struct SharedMovingAverageStore(pub Arc<InMemoryStateStore<MovingAverageState>>);

Wrapper struct to implement StateStore on Arc<InMemoryStateStore<MovingAverageState>>

Tuple Fields

0: Arc<InMemoryStateStore<MovingAverageState>>

Trait Implementations

impl Clone for SharedMovingAverageStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SharedMovingAverageStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl StateStore<MovingAverageState> for SharedMovingAverageStore

fn get(&self) -> StateResult<Option<MovingAverageState>>

Get a read-only reference to the current state.

fn set(&self, state: MovingAverageState) -> StateResult<()>

Set the state to a new value.

fn update_with( &self, f: Box<dyn FnOnce(Option<MovingAverageState>) -> MovingAverageState + Send>, ) -> StateResult<MovingAverageState>

Update the state using a boxed function.

fn reset(&self) -> StateResult<()>

Reset the state to its initial value or clear it.

fn is_initialized(&self) -> bool

Check if the state has been initialized.

fn initial_state(&self) -> Option<MovingAverageState>

Get the initial state value if one was provided.