Struct AsyncShared 

pub struct AsyncShared<T> { /* private fields */ }

Thread safe shared value, a thin wrapper over Arc<RwLock<T>>.

The Shared counterpart for values that cross threads. Access methods return None when the lock is poisoned or cannot be taken.

Implementations

impl<T> AsyncShared<T>

pub fn new(data: T) -> Self

Wraps a value into a new shared cell with one reference.

pub fn try_consume(self) -> Result<T, Self>

Unwraps the value when this is the last reference, otherwise gives the handle back untouched.

pub fn read(&self) -> Option<RwLockReadGuard<'_, T>>

Takes a read lock, blocking until it is free, or returns None when the lock is poisoned.

pub fn write(&self) -> Option<RwLockWriteGuard<'_, T>>

Takes a write lock, blocking until it is free, or returns None when the lock is poisoned.

pub fn swap(&self, data: T) -> Option<T>

Replaces the value and returns the old one, or None when the lock is poisoned.

pub fn references_count(&self) -> usize

Returns how many handles point at this value.

pub fn does_share_reference(&self, other: &Self) -> bool

Returns true when both handles point at the same value.

Trait Implementations

impl<T> Clone for AsyncShared<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Default> Default for AsyncShared<T>

fn default() -> AsyncShared<T>

Returns the “default value” for a type.