Skip to main content

Owner

Struct Owner 

Source
pub struct Owner { /* private fields */ }
Expand description

A reactive owner, which manages

  1. the cancellation of Effects,
  2. providing and accessing environment data via provide_context and use_context,
  3. running cleanup functions defined via Owner::on_cleanup, and
  4. an arena storage system to provide Copy handles via ArenaItem, which is what allows types like RwSignal, Memo, and so on to be Copy.

Every effect and computed reactive value has an associated Owner. While it is running, this is marked as the current Owner. Whenever it re-runs, this Owner is cleared by calling Owner::with_cleanup. This runs cleanup functions, cancels any Effects created during the last run, drops signals stored in the arena, and so on, because those effects and signals will be re-created as needed during the next run.

When the owner is ultimately dropped, it will clean up its owned resources in the same way.

The “current owner” is set on the thread-local basis: whenever one of these reactive nodes is running, it will set the current owner on its thread with Owner::with or Owner::set, allowing other reactive nodes implicitly to access the fact that it is currently the owner.

For a longer discussion of the ownership model, see here.

Implementations§

Source§

impl Owner

Source

pub fn use_context_bidirectional<T>(&self) -> Option<T>
where T: Clone + 'static,

Searches for items stored in context in either direction, either among parents or among descendants.

Source§

impl Owner

Source

pub fn debug_id(&self) -> usize

Returns a unique identifier for this owner, which can be used to identify it for debugging purposes.

Intended for debugging only; this is not guaranteed to be stable between runs.

Source

pub fn ancestry(&self) -> Vec<usize>

Returns the list of parents, grandparents, and ancestors, with values corresponding to Owner::debug_id for each.

Intended for debugging only; this is not guaranteed to be stable between runs.

Source

pub fn new() -> Owner

Creates a new Owner and registers it as a child of the current Owner, if there is one.

Source

pub fn new_root( shared_context: Option<Arc<dyn SharedContext + Sync + Send>>, ) -> Owner

Creates a new “root” context with the given SharedContext, which allows sharing data between the server and client.

Only one SharedContext needs to be created per request, and will be automatically shared by any other Owners created under this one.

Source

pub fn parent(&self) -> Option<Owner>

Returns the parent of this Owner, if any.

None when:

  • This is a root owner
  • The parent has been dropped
Source

pub fn child(&self) -> Owner

Creates a new Owner that is the child of the current Owner, if any.

Source

pub fn set(&self)

Sets this as the current Owner.

Source

pub fn with<T>(&self, fun: impl FnOnce() -> T) -> T

Runs the given function with this as the current Owner.

Source

pub fn with_cleanup<T>(&self, fun: impl FnOnce() -> T) -> T

Cleans up this owner, the given function with this as the current Owner.

Source

pub fn cleanup(&self)

Cleans up this owner in the following order:

  1. Runs cleanup on all children,
  2. Runs all cleanup functions registered with Owner::on_cleanup,
  3. Drops the values of any arena-allocated ArenaItems.
Source

pub fn on_cleanup(fun: impl FnOnce() + Send + Sync + 'static)

Registers a function to be run the next time the current owner is cleaned up.

Because the ownership model is associated with reactive nodes, each “decision point” in an application tends to have a separate Owner: as a result, these cleanup functions often fill the same need as an “on unmount” function in other UI approaches, etc.

Source

pub fn current() -> Option<Owner>

Returns the current Owner, if any.

Source

pub fn shared_context(&self) -> Option<Arc<dyn SharedContext + Sync + Send>>

Returns the SharedContext associated with this owner, if any.

Source

pub fn unset(self)

Removes this from its state as the thread-local owner and drops it.

Source

pub fn current_shared_context() -> Option<Arc<dyn SharedContext + Sync + Send>>

Returns the current SharedContext, if any.

Source

pub fn with_hydration<T>(fun: impl FnOnce() -> T + 'static) -> T

Runs the given function, after indicating that the current SharedContext should be prepared to handle any data created in the function.

Source

pub fn with_no_hydration<T>(fun: impl FnOnce() -> T + 'static) -> T

Runs the given function, after indicating that the current SharedContext should /// not handle data created in this function.

Source

pub fn pause(&self)

Pauses the execution of side effects for this owner, and any of its descendants.

If this owner is the owner for an Effect or RenderEffect, this effect will not run until Owner::resume is called. All children of this effects are also paused.

Any notifications will be ignored; effects that are notified will paused will not run when resumed, until they are notified again by a source after being resumed.

Source

pub fn paused(&self) -> bool

Whether this owner has been paused by Owner::pause.

Source

pub fn resume(&self)

Resumes side effects that have been paused by Owner::pause.

All children will also be resumed.

This will not cause side effects that were notified while paused to run, until they are notified again by a source after being resumed.

Trait Implementations§

Source§

impl Clone for Owner

Source§

fn clone(&self) -> Owner

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for Owner

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for Owner

Source§

fn default() -> Owner

Returns the “default value” for a type. Read more
Source§

impl PartialEq for Owner

Source§

fn eq(&self, other: &Owner) -> bool

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

Auto Trait Implementations§

§

impl Freeze for Owner

§

impl !RefUnwindSafe for Owner

§

impl Send for Owner

§

impl Sync for Owner

§

impl Unpin for Owner

§

impl !UnwindSafe for Owner

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<E, T, Request, Encoding> FromReq<Patch<Encoding>, Request, E> for T
where Request: Req<E> + Send + 'static, Encoding: Decodes<T>, E: FromServerFnError,

Source§

async fn from_req(req: Request) -> Result<T, E>

Attempts to deserialize the arguments from a request.
Source§

impl<E, T, Request, Encoding> FromReq<Post<Encoding>, Request, E> for T
where Request: Req<E> + Send + 'static, Encoding: Decodes<T>, E: FromServerFnError,

Source§

async fn from_req(req: Request) -> Result<T, E>

Attempts to deserialize the arguments from a request.
Source§

impl<E, T, Request, Encoding> FromReq<Put<Encoding>, Request, E> for T
where Request: Req<E> + Send + 'static, Encoding: Decodes<T>, E: FromServerFnError,

Source§

async fn from_req(req: Request) -> Result<T, E>

Attempts to deserialize the arguments from a request.
Source§

impl<E, Encoding, Response, T> FromRes<Patch<Encoding>, Response, E> for T
where Response: ClientRes<E> + Send, Encoding: Decodes<T>, E: FromServerFnError,

Source§

async fn from_res(res: Response) -> Result<T, E>

Attempts to deserialize the outputs from a response.
Source§

impl<E, Encoding, Response, T> FromRes<Post<Encoding>, Response, E> for T
where Response: ClientRes<E> + Send, Encoding: Decodes<T>, E: FromServerFnError,

Source§

async fn from_res(res: Response) -> Result<T, E>

Attempts to deserialize the outputs from a response.
Source§

impl<E, Encoding, Response, T> FromRes<Put<Encoding>, Response, E> for T
where Response: ClientRes<E> + Send, Encoding: Decodes<T>, E: FromServerFnError,

Source§

async fn from_res(res: Response) -> Result<T, E>

Attempts to deserialize the outputs from a response.
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<E, T, Encoding, Request> IntoReq<Patch<Encoding>, Request, E> for T
where Request: ClientReq<E>, Encoding: Encodes<T>, E: FromServerFnError,

Source§

fn into_req(self, path: &str, accepts: &str) -> Result<Request, E>

Attempts to serialize the arguments into an HTTP request.
Source§

impl<E, T, Encoding, Request> IntoReq<Post<Encoding>, Request, E> for T
where Request: ClientReq<E>, Encoding: Encodes<T>, E: FromServerFnError,

Source§

fn into_req(self, path: &str, accepts: &str) -> Result<Request, E>

Attempts to serialize the arguments into an HTTP request.
Source§

impl<E, T, Encoding, Request> IntoReq<Put<Encoding>, Request, E> for T
where Request: ClientReq<E>, Encoding: Encodes<T>, E: FromServerFnError,

Source§

fn into_req(self, path: &str, accepts: &str) -> Result<Request, E>

Attempts to serialize the arguments into an HTTP request.
Source§

impl<E, Response, Encoding, T> IntoRes<Patch<Encoding>, Response, E> for T
where Response: TryRes<E>, Encoding: Encodes<T>, E: FromServerFnError + Send, T: Send,

Source§

async fn into_res(self) -> Result<Response, E>

Attempts to serialize the output into an HTTP response.
Source§

impl<E, Response, Encoding, T> IntoRes<Post<Encoding>, Response, E> for T
where Response: TryRes<E>, Encoding: Encodes<T>, E: FromServerFnError + Send, T: Send,

Source§

async fn into_res(self) -> Result<Response, E>

Attempts to serialize the output into an HTTP response.
Source§

impl<E, Response, Encoding, T> IntoRes<Put<Encoding>, Response, E> for T
where Response: TryRes<E>, Encoding: Encodes<T>, E: FromServerFnError + Send, T: Send,

Source§

async fn into_res(self) -> Result<Response, E>

Attempts to serialize the output into an HTTP response.
Source§

impl<T> SerializableKey for T

Source§

fn ser_key(&self) -> String

Serializes the key to a unique string. Read more
Source§

impl<T> StorageAccess<T> for T

Source§

fn as_borrowed(&self) -> &T

Borrows the value.
Source§

fn into_taken(self) -> T

Takes the value.
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.