Struct CoMapTransaction 

pub struct CoMapTransaction<S, K, V>
where
    S: AnyBlockStorage,
    K: Hash + Ord + Clone + Serialize + DeserializeOwned + Send + Sync + 'static,
    V: Clone + Serialize + DeserializeOwned + Send + Sync + 'static,
{ /* private fields */ }

Implementations

impl<S, K, V> CoMapTransaction<S, K, V>

where S: AnyBlockStorage, K: Hash + Ord + Clone + Serialize + DeserializeOwned + Send + Sync + 'static, V: Clone + Serialize + DeserializeOwned + Send + Sync + 'static,

pub async fn get(&self, key: &K) -> Result<Option<V>, StorageError>

pub async fn contains_key(&self, key: &K) -> Result<bool, StorageError>

pub fn stream( &self, ) -> impl Stream<Item = Result<(K, V), StorageError>> + use<S, K, V>

pub fn stream_filter<F: FnMut(&V) -> bool>( &self, predicate: F, ) -> impl Stream<Item = Result<K, StorageError>> + use<S, K, V, F>

pub async fn insert(&mut self, key: K, value: V) -> Result<(), StorageError>

pub async fn remove(&mut self, key: K) -> Result<Option<V>, StorageError>

pub async fn update_or_insert<F>( &mut self, key: K, update: F, ) -> Result<(), StorageError>

where V: Default, F: FnOnce(&mut V) + Send,

Update (or insert default) value.

pub async fn try_update_or_insert_async<F, Fut>( &mut self, key: K, update: F, ) -> Result<(), StorageError>

where V: Default, F: FnOnce(V) -> Fut + Send, Fut: Future<Output = Result<V, StorageError>> + Send,

Update (or insert default) value.

pub async fn update<F>(&mut self, key: K, update: F) -> Result<(), StorageError>

where F: FnOnce(&mut V) + Send,

Update value, ignore if key not exists.

pub async fn try_update_async<F, Fut>( &mut self, key: K, update: F, ) -> Result<(), StorageError>

where F: FnOnce(V) -> Fut + Send, Fut: Future<Output = Result<V, StorageError>> + Send,

Update value, ignore if key not exists.

pub async fn update_stream( &mut self, keys_to_update: impl Stream<Item = Result<K, StorageError>>, update: impl FnMut(&K, &mut V) + Send, ) -> Result<(), StorageError>

pub async fn remove_stream( &mut self, keys_to_remove: impl Stream<Item = Result<K, StorageError>>, ) -> Result<(), StorageError>

pub async fn store(&mut self) -> Result<CoMap<K, V>, StorageError>

Store as new CoMap

Trait Implementations

impl<S, K, V> Clone for CoMapTransaction<S, K, V>

where S: AnyBlockStorage + Clone, K: Hash + Ord + Clone + Serialize + DeserializeOwned + Send + Sync + 'static + Clone, V: Clone + Serialize + DeserializeOwned + Send + Sync + 'static + Clone,

fn clone(&self) -> CoMapTransaction<S, K, V>

Returns a duplicate of the value.

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

Performs copy-assignment from source.