Struct ArcAsyncDerived

pub struct ArcAsyncDerived<T> {
    pub(crate) value: Arc<RwLock<SendOption<T>>>,
    pub(crate) wakers: Arc<RwLock<Vec<Waker>>>,
    pub(crate) inner: Arc<RwLock<ArcAsyncDerivedInner>>,
    pub(crate) loading: Arc<AtomicBool>,
}

A reactive value that is derived by running an asynchronous computation in response to changes in its sources.

When one of its dependencies changes, this will re-run its async computation, then notify other values that depend on it that it has changed.

This is a reference-counted type, which is Clone but not Copy. For arena-allocated Copy memos, use AsyncDerived.

Examples

let signal1 = RwSignal::new(0);
let signal2 = RwSignal::new(0);
let derived = ArcAsyncDerived::new(move || async move {
  // reactive values can be tracked anywhere in the `async` block
  let value1 = signal1.get();
  tokio::time::sleep(std::time::Duration::from_millis(25)).await;
  let value2 = signal2.get();

  value1 + value2
});

// the value can be accessed synchronously as `Option<T>`
assert_eq!(derived.get(), None);
// we can also .await the value, i.e., convert it into a Future
assert_eq!(derived.clone().await, 0);
assert_eq!(derived.get(), Some(0));

signal1.set(1);
// while the new value is still pending, the signal holds the old value
tokio::time::sleep(std::time::Duration::from_millis(5)).await;
assert_eq!(derived.get(), Some(0));

// setting multiple dependencies will hold until the latest change is ready
signal2.set(1);
assert_eq!(derived.await, 2);

Core Trait Implementations

• .get() clones the current value as an Option<T>. If you call it within an effect, it will cause that effect to subscribe to the memo, and to re-run whenever the value of the memo changes.
  • .get_untracked() clones the value of without reactively tracking it.
• .read() returns a guard that allows accessing the value by reference. If you call it within an effect, it will cause that effect to subscribe to the memo, and to re-run whenever the value changes.
  • .read_untracked() gives access to the current value without reactively tracking it.
• .with() allows you to reactively access the value without cloning by applying a callback function.
  • .with_untracked() allows you to access the value by applying a callback function without reactively tracking it.
• IntoFuture allows you to create a Future that resolves when this resource is done loading.

Fields

value: Arc<RwLock<SendOption<T>>>

wakers: Arc<RwLock<Vec<Waker>>>

inner: Arc<RwLock<ArcAsyncDerivedInner>>

loading: Arc<AtomicBool>

Implementations

impl<T> ArcAsyncDerived<T>

where T: 'static,

pub fn new<Fut>( fun: impl Fn() -> Fut + Send + Sync + 'static, ) -> ArcAsyncDerived<T>

where T: Send + Sync + 'static, Fut: Future<Output = T> + Send + 'static,

Creates a new async derived computation.

This runs eagerly: i.e., calls fun once when created and immediately spawns the Future as a new task.

pub fn new_with_initial<Fut>( initial_value: Option<T>, fun: impl Fn() -> Fut + Send + Sync + 'static, ) -> ArcAsyncDerived<T>

where T: Send + Sync + 'static, Fut: Future<Output = T> + Send + 'static,

Creates a new async derived computation with an initial value as a fallback, and begins running the Future eagerly to get the actual first value.

pub fn new_unsync<Fut>(fun: impl Fn() -> Fut + 'static) -> ArcAsyncDerived<T>

where T: 'static, Fut: Future<Output = T> + 'static,

Creates a new async derived computation that will be guaranteed to run on the current thread.

This runs eagerly: i.e., calls fun once when created and immediately spawns the Future as a new task.

pub fn new_unsync_with_initial<Fut>( initial_value: Option<T>, fun: impl Fn() -> Fut + 'static, ) -> ArcAsyncDerived<T>

where T: 'static, Fut: Future<Output = T> + 'static,

Creates a new async derived computation with an initial value as a fallback, and begins running the Future eagerly to get the actual first value.

pub fn ready(&self) -> AsyncDerivedReadyFuture

Returns a Future that is ready when this resource has next finished loading.

impl<T> ArcAsyncDerived<T>

where T: 'static,

pub fn by_ref(&self) -> AsyncDerivedRefFuture<T>

Returns a Future that resolves when the computation is finished, and accesses the inner value by reference rather than by cloning it.

Trait Implementations

impl<T> Clone for ArcAsyncDerived<T>

fn clone(&self) -> ArcAsyncDerived<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for ArcAsyncDerived<T>

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

Formats the value using the given formatter.

impl<T> DefinedAt for ArcAsyncDerived<T>

fn defined_at(&self) -> Option<&'static Location<'static>>

Returns the location at which the signal was defined. This is usually simply None in release mode.

impl<T, S> From<ArcAsyncDerived<T>> for AsyncDerived<T, S>

where T: 'static, S: Storage<ArcAsyncDerived<T>>,

fn from(value: ArcAsyncDerived<T>) -> AsyncDerived<T, S>

Converts to this type from the input type.

impl<T, S> From<AsyncDerived<T, S>> for ArcAsyncDerived<T>

where T: 'static, S: Storage<ArcAsyncDerived<T>>,

fn from(value: AsyncDerived<T, S>) -> ArcAsyncDerived<T>

Converts to this type from the input type.

impl<T> FromLocal<ArcAsyncDerived<T>> for AsyncDerived<T, LocalStorage>

where T: 'static,

fn from_local(value: ArcAsyncDerived<T>) -> AsyncDerived<T, LocalStorage>

Converts between the types.

impl<T> IntoFuture for ArcAsyncDerived<T>

where T: Clone + 'static,

type Output = T

The output that the future will produce on completion.

type IntoFuture = AsyncDerivedFuture<T>

Which kind of future are we turning this into?

fn into_future(self) -> <ArcAsyncDerived<T> as IntoFuture>::IntoFuture

Creates a future from a value.

impl<T> IsDisposed for ArcAsyncDerived<T>

where T: 'static,

fn is_disposed(&self) -> bool

If true, the signal cannot be accessed without a panic.

impl<T> Notify for ArcAsyncDerived<T>

where T: 'static,

fn notify(&self)

Notifies subscribers of a change in this signal.

impl<T> ReactiveNode for ArcAsyncDerived<T>

fn mark_dirty(&self)

Notifies the source’s dependencies that it has changed.

fn mark_check(&self)

Notifies the source’s dependencies that it may have changed.

fn mark_subscribers_check(&self)

Marks that all subscribers need to be checked.

fn update_if_necessary(&self) -> bool

Regenerates the value for this node, if needed, and returns whether it has actually changed or not.

impl<T> ReadUntracked for ArcAsyncDerived<T>

where T: 'static,

type Value = ReadGuard<Option<T>, Mapped<AsyncPlain<SendOption<T>>, Option<T>>>

The guard type that will be returned, which can be dereferenced to the value.

fn try_read_untracked( &self, ) -> Option<<ArcAsyncDerived<T> as ReadUntracked>::Value>

Returns the guard, or None if the signal has already been disposed.

fn read_untracked(&self) -> Self::Value

Returns the guard.

fn custom_try_read(&self) -> Option<Option<Self::Value>>

This is a backdoor to allow overriding the Read::try_read implementation despite it being auto implemented.

impl<T> Source for ArcAsyncDerived<T>

fn add_subscriber(&self, subscriber: AnySubscriber)

Adds a subscriber to this source’s list of dependencies.

fn remove_subscriber(&self, subscriber: &AnySubscriber)

Removes a subscriber from this source’s list of dependencies.

fn clear_subscribers(&self)

Remove all subscribers from this source’s list of dependencies.

impl<T> Subscriber for ArcAsyncDerived<T>

fn add_source(&self, source: AnySource)

Adds a subscriber to this subscriber’s list of dependencies.

fn clear_sources(&self, subscriber: &AnySubscriber)

Clears the set of sources for this subscriber.

impl<T> ToAnySource for ArcAsyncDerived<T>

where T: 'static,

fn to_any_source(&self) -> AnySource

Converts this type to its type-erased equivalent.

impl<T> ToAnySubscriber for ArcAsyncDerived<T>

where T: 'static,

fn to_any_subscriber(&self) -> AnySubscriber

Converts this type to its type-erased equivalent.

impl<T> Write for ArcAsyncDerived<T>

where T: 'static,

type Value = Option<T>

The type of the signal’s value.

fn try_write(&self) -> Option<impl UntrackableGuard>

Returns the guard, or None if the signal has already been disposed.

fn try_write_untracked(&self) -> Option<impl DerefMut>

or None if the signal has already been disposed.

fn write(&self) -> impl UntrackableGuard

Returns the guard.

fn write_untracked(&self) -> impl DerefMut

Returns a guard that will not notify subscribers when dropped.