Struct RwLock

pub struct RwLock<T, Codec = Default> { /* private fields */ }

A lock that allows reading and writing of a shared value, possibly stored on a remote endpoint.

This can be cloned and sent to remote endpoints

Implementations

impl<T, Codec> RwLock<T, Codec>

pub fn owner(&self) -> Option<&Arc<TokioRwLock<T>>>

Returns owner if it exist

pub async fn owner_read(&self) -> Option<TokioRwLockReadGuard<'_, T>>

Locks the owner shared value for reading and returns a reference to it, without synchronizing with remote endpoints

pub async fn owner_write(&self) -> Option<TokioRwLockWriteGuard<'_, T>>

Locks the owner shared value for reading and writing and returns a mutable reference to it, without synchronizing with remote endpoints

impl<T: RemoteSend + Clone + Sync, Codec: Codec> RwLock<T, Codec>

pub fn new(value: T) -> Self

Creates a new RwLock<T> with an owner with the specified shared value.

pub async fn read(&self) -> Result<RwLockReadGuard<'_, T, Codec>, LockError>

Locks the current shared value for reading and returns a reference to it.

pub async fn write(&self) -> Result<RwLockWriteGuard<'_, T, Codec>, LockError>

Locks the current shared value for reading and writing and returns a mutable reference to it.

To commit the new value RwLockWriteGuard::commit must be called, otherwise the changes will be lost.

Trait Implementations

impl<T, Codec> Clone for RwLock<T, Codec>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'de, T: RemoteSend + Clone + Sync, Codec: Codec> Deserialize<'de> for RwLock<T, Codec>

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T: RemoteSend + Clone + Sync, Codec: Codec> Serialize for RwLock<T, Codec>

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.