Struct Writer 

pub struct Writer<'a, T>
where
    T: Storable + 'static,
{
    slot: Pin<&'a Slot<T>>,
    waiter: Waiter<'a>,
    marker: PhantomData<fn(T)>,
}

Writer for a Storable type.

Allows Actors to write a particular type read by another actor. The generic type T from the writer specifies the type of the value that is being written.

Usage

All Readers are guaranteed to be able to observe every write. For this reason, Writer::write is an async method. It will resolve once all Actors awaiting a Reader for the same type had the chance to read the value. Typically, this only occurs when trying to write two values back to back. If all Readers already had the chance to read the value, Writer::write will resolve immediately. The same is true for Writer::modify.

Examples

// Writing a value.
#[veecle_os_runtime::actor]
async fn foo_writer(mut writer: Writer<'_, Foo>) -> std::convert::Infallible {
    loop {
        // This call will yield to any readers needing to read the last value.
        writer.write(Foo::default()).await;
    }
}

// Modifying a value.
#[veecle_os_runtime::actor]
async fn foo_writer(
    mut writer: Writer<'_, Foo>,
) -> std::convert::Infallible {
    loop {
        // This call will yield to any readers needing to read the last value.
        // The closure will run after yielding and right before continuing to the rest of the function.
        writer.modify(|previous_value: &mut Option<Foo>| {
            // mutate the previous value
        }).await;
    }
}

Writer::ready allows separating the “waiting” from the “writing”, After Writer::ready returns, the next write or modification will happen immediately.

#[veecle_os_runtime::actor]
async fn foo_writer(mut writer: Writer<'_, Foo>) -> std::convert::Infallible {
    loop {
        // This call may yield to any readers needing to read the last value.
        writer.ready().await;

        // This call will return immediately.
        writer.write(Foo::default()).await;
        // This call will yield to any readers needing to read the last value.
        writer.write(Foo::default()).await;
    }
}

Fields

slot: Pin<&'a Slot<T>>

waiter: Waiter<'a>

marker: PhantomData<fn(T)>

Implementations

impl<T> Writer<'_, T>

where T: Storable + 'static,

pub async fn write(&mut self, item: <T as Storable>::DataType)

Available on crate feature data-support-can only.

Writes a new value and notifies readers.

pub async fn ready(&mut self)

Available on crate feature data-support-can only.

Waits for the writer to be ready to perform a write operation.

After awaiting this method, the next call to Writer::write() or Writer::modify() is guaranteed to resolve immediately.

pub async fn modify( &mut self, f: impl FnOnce(&mut Option<<T as Storable>::DataType>), )

Available on crate feature data-support-can only.

Updates the value in-place and notifies readers.

pub fn read<U>( &self, f: impl FnOnce(Option<&<T as Storable>::DataType>) -> U, ) -> U

Available on crate feature data-support-can only.

Reads the current value of a type.

This method takes a closure to ensure the reference is not held across await points.

Trait Implementations

impl<'a, T> Debug for Writer<'a, T>

where T: Debug + Storable + 'static,

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

Formats the value using the given formatter.

impl<'a, T> StoreRequest<'a> for Writer<'a, T>

where T: Storable + 'static,