Type Alias zng_var::ResponseVar

pub type ResponseVar<T> = ReadOnlyVar<Response<T>, ArcVar<Response<T>>>;

Variable used to listen to a one time signal that an async operation has completed.

Use response_var or response_done_var to init.

Aliased Type

struct ResponseVar<T>(/* private fields */);

Implementations

impl<T: VarValue> ResponseVar<T>

pub fn with_rsp<R>(&self, read: impl FnOnce(&T) -> R) -> Option<R>

Visit the response, if present.

pub fn with_new_rsp<R>(&self, read: impl FnOnce(&T) -> R) -> Option<R>

Visit the response, if present and new.

pub fn is_done(&self) -> bool

If the response is received.

pub fn is_waiting(&self) -> bool

If the response is not received yet.

pub fn rsp(&self) -> Option<T>

Clone the response value, if present.

pub async fn wait_rsp(&self) -> T

Returns a future that awaits until a response is received and then returns a clone.

pub async fn wait_into_rsp(self) -> T

Returns a future that awaits until a response is received and then returns it.

Will clone the value if the variable is shared.

pub async fn wait_done(&self)

Returns a future that awaits until a response is received.

pub fn rsp_new(&self) -> Option<T>

Clone the response, if present and new.

pub fn into_rsp(self) -> Option<T>

Into response, if received.

Clones if the variable is has more than one strong reference.

pub fn map_rsp<O, I, M>(&self, waiting_value: I, map: M) -> impl Var<O>

where O: VarValue, I: Fn() -> O + Send + Sync + 'static, M: FnOnce(&T) -> O + Send + 'static,

Map the response value using map, if the variable is awaiting a response uses the waiting_value first.