Struct SharedStorageImpl 

pub struct SharedStorageImpl { /* private fields */ }

Available on crate feature shared_storage_impl only.

An implementation of type-based shared storage.

See SharedStorage for more info.
See also Fork, Update, Join.

Internal Structure

Item entries are stored in Arc<std::sync::Mutex<HashMap<TypeId, StorageItem>>> which is cloned in Fork and shared between branches.
StorageItem has type Arc<async_lock::RwLock<...>> which allows for per entry locking without holding a lock for the entire HashMap.

Implementations

impl SharedStorageImpl

pub fn new() -> Self

Constructs new SharedStorageImpl.

Trait Implementations

impl Clone for SharedStorageImpl

fn clone(&self) -> SharedStorageImpl

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SharedStorageImpl

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

Formats the value using the given formatter.

impl Default for SharedStorageImpl

fn default() -> SharedStorageImpl

Returns the “default value” for a type.

impl Fork for SharedStorageImpl

fn fork(&self) -> Self

Creates a forked instance of the implementor.

impl Join for SharedStorageImpl

fn join(&mut self, _others: Box<[Self]>)

Joins the state of multiple others into this instance.

impl SharedStorage for SharedStorageImpl

fn get<T>(&self) -> impl Future<Output = Option<impl Deref<Target = T>>> + Send

where T: 'static,

Gets reference of a value with type T from storage if it is present.

fn get_mut<T>( &mut self, ) -> impl Future<Output = Option<impl DerefMut<Target = T>>> + Send

where T: 'static,

Gets mutable reference of a value with type T from storage if it is present.

fn insert<T>(&mut self, val: T) -> impl Future<Output = Option<T>> + Send

where T: Send + Sync + 'static,

Inserts value with type T to storage and returns the value that was there previously if it was there.

fn insert_with_if_absent<T, E>( &self, fut: impl Future<Output = Result<T, E>> + Send, ) -> impl Future<Output = Result<(), E>> + Send

where T: Send + Sync + 'static, E: Send,

Inserts value with type T to storage if it doesn’t contain it.

fn remove<T>(&mut self) -> impl Future<Output = Option<T>> + Send

where T: 'static,

Removes and returns value with type T from storage if it is present.

impl Update for SharedStorageImpl

fn update_from(&mut self, _other: Self)

Merges or synchronizes the state of other into self.