Struct remoc_obs::hash_set::MirroredHashSet

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

A hash set that is mirroring an observable hash set.

Implementations

impl<T, Codec> MirroredHashSet<T, Codec> where
    T: RemoteSend + Eq + Hash + Clone,
    Codec: Codec, 

pub async fn borrow(&self) -> Result<MirroredHashSetRef<'_, T>, RecvError>

Returns a reference to the current value of the hash set.

Updates are paused while the read lock is held.

This method returns an error if the observed hash set has been dropped or the connection to it failed before it was marked as done by calling ObservableHashSet::done. In this case the mirrored contents at the point of loss of connection can be obtained using detach.

pub async fn borrow_and_update(
    &mut self
) -> Result<MirroredHashSetRef<'_, T>, RecvError>

Returns a reference to the current value of the hash set and marks it as seen.

Thus changed will not return immediately until the value changes after this method returns.

Updates are paused while the read lock is held.

This method returns an error if the observed hash set has been dropped or the connection to it failed before it was marked as done by calling ObservableHashSet::done. In this case the mirrored contents at the point of loss of connection can be obtained using detach.

pub async fn detach(self) -> HashSet<T>

Stops updating the hash set and returns its current contents.

pub async fn changed(&mut self)

Waits for a change and marks the newest value as seen.

This also returns when connection to the observed hash set has been lost or the hash set has been marked as done.

pub async fn subscribe(
    &self,
    buffer: usize
) -> Result<HashSetSubscription<T, Codec>, RecvError>

Subscribes to change events from this mirrored hash set.

The current contents of the hash set is included with the subscription.

buffer specifies the maximum size of the event buffer for this subscription in number of events. If it is exceeded the subscription is shed and the receiver gets a RecvError::Lagged.

pub async fn subscribe_incremental(
    &self,
    buffer: usize
) -> Result<HashSetSubscription<T, Codec>, RecvError>

Subscribes to change events from this mirrored hash set with incremental sending of the current contents.

The current contents of the hash set are sent incrementally.

buffer specifies the maximum size of the event buffer for this subscription in number of events. If it is exceeded the subscription is shed and the receiver gets a RecvError::Lagged.

Trait Implementations

impl<T, Codec> Debug for MirroredHashSet<T, Codec>

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

Formats the value using the given formatter.

impl<T, Codec> Drop for MirroredHashSet<T, Codec>

fn drop(&mut self)

Executes the destructor for this type.