Struct Backed 

pub struct Backed<T> { /* private fields */ }

A signal whose producer is started by the first reader that calls open. The value is not handed out until the producer is running and ready. The gate counts readers so the producer can retire once none are left (unwatched, TaskNode::retire).

Implementations

impl<T> Backed<T>

pub const fn new(inner: T) -> Self

Wrap inner as a backed signal.

pub fn openers(&self) -> u32

How many Open guards are alive right now.

pub async fn unwatched(&self, cooldown: Duration)

Resolve once no reader has held the gate for cooldown, continuously.

Trait Implementations

impl<T> Deref for Backed<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &T

Dereferences the value.

impl<T: Sync + 'static> Gated for Backed<T>

type Handle = Open<T>

Handle returned by open after the gate passes. Counting gates return a guard; simple gates return &'static Self.

fn admit(&'static self) -> Open<T>

Admit a reader before ensure runs, so the producer sees an incoming reader and a cancelled open can roll back.

async fn ensure( &'static self, caller: &'static TaskNode, entry: &'static Coupling, )

Ensure the producer of entry is serving from the perspective of caller.

impl<T: Observable> Observable for Backed<T>

Available on crate feature coupling-observe only.

fn change_token(&self) -> u32

Return a token that changes when the signal is written.