Struct ReducingState 

pub struct ReducingState<B, F>
where
    B: StateBackend,
    F: Fn(Vec<u8>, Vec<u8>) -> Vec<u8> + Send + Sync,
{ /* private fields */ }

Reducing state.

Implementations

impl<B, F> ReducingState<B, F>

where B: StateBackend, F: Fn(Vec<u8>, Vec<u8>) -> Vec<u8> + Send + Sync,

pub fn new( backend: Arc<B>, namespace: String, key: Vec<u8>, reduce_fn: F, ) -> Self

Create a new reducing state.

pub async fn get(&self) -> Result<Option<Vec<u8>>>

Get the reduced value.

pub async fn add(&self, value: Vec<u8>) -> Result<()>

Add a value (will be reduced with existing value).

Trait Implementations

impl<B, F> KeyedState for ReducingState<B, F>

where B: StateBackend, F: Fn(Vec<u8>, Vec<u8>) -> Vec<u8> + Send + Sync,

fn key(&self) -> &[u8]

Get the state key.

async fn clear(&self) -> Result<()>

Clear the state.