Struct Atomic 

pub struct Atomic<Loc> { /* private fields */ }

A location wrapper that provides atomicity guarantees within a Tick.

An Atomic context establishes a happens-before relationship between operations:

• Downstream computations from atomic() are associated with an internal tick
• Outputs from end_atomic() are held until all computations in the tick complete
• Snapshots via use::atomic are guaranteed to reflect all updates from associated end_atomic()

This ensures read-after-write consistency: if a client receives an acknowledgement from end_atomic(), any subsequent use::atomic snapshot will include the effects of that acknowledged operation.

Trait Implementations

impl<Loc: Clone> Clone for Atomic<Loc>

fn clone(&self) -> Atomic<Loc>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a, L> Location<'a> for Atomic<L>

where L: Location<'a>,

type Root = <L as Location<'a>>::Root

The root location type for this location.

type DropConsistency = Atomic<<L as Location<'a>>::DropConsistency>

Location type with consistency guarantees dropped for the live collection on it.

fn consistency() -> Option<ClusterConsistency>

Gets the runtime enum variant for the current consistency level, if this is a cluster.

fn root(&self) -> Self::Root

Returns the root location for this location.

fn drop_consistency(&self) -> Self::DropConsistency

This location but with consistency guarantees dropped for the live collection

fn with_consistency_of<L2: Location<'a, DropConsistency = Self::DropConsistency>>( &self, ) -> L2

Updates the consistency guarantees to match that of the given location.

fn try_tick(&self) -> Option<Tick<Self>>

Attempts to create a new Tick clock domain at this location.

fn id(&self) -> LocationId

Returns the unique identifier for this location.

fn tick(&self) -> Tick<Self>

Creates a new Tick clock domain at this location.

fn source_iter<T, E>( &self, e: impl QuotedWithContext<'a, E, Self>, ) -> Stream<T, Self::DropConsistency, Bounded, TotalOrder, ExactlyOnce>

where E: IntoIterator<Item = T>, Self: Sized,

Creates a bounded stream from an iterator.

fn singleton<T>( &self, e: impl QuotedWithContext<'a, T, Self>, ) -> Singleton<T, Self::DropConsistency, Bounded>

where Self: Sized,

Constructs a Singleton materialized at this location with the given static value.

fn singleton_future<F>( &self, e: impl QuotedWithContext<'a, F, Self>, ) -> Singleton<F::Output, Self::DropConsistency, Bounded>

where F: Future, Self: Sized,

Constructs a Singleton by resolving an async Future to completion.

fn forward_ref<S>(&self) -> (ForwardHandle<'a, S>, S)

where S: CycleCollection<'a, ForwardRef, Location = Self>,

Creates a forward reference, allowing a stream to be used before its source is defined.