Struct Registry 

pub struct Registry { /* private fields */ }

The connection set of one application.

Implementations

impl Registry

pub fn new(config: Config) -> Arc<Registry>

pub fn value(&self) -> Value

The roster as a Beck value: Map[Str, Int], actor to connections.

pub fn watch(&self) -> Receiver<Value>

Wake on every change to it. A subscription watches this only when the program’s page reads presence — a program that never asks who is connected must not re-render when somebody connects.

pub fn here(&self) -> usize

How many actors are in the roster.

pub fn refused(&self) -> u64

How many joins the capacity refused, for the life of this process.

pub fn join(self: &Arc<Self>, actor: &str) -> Guard

Record a connection. The roster holds it until the returned guard is dropped.

A guard rather than a pair of calls, for the reason every other guard in this crate is one: a subscription ends by returning, by erroring or by its socket dying, and a roster that only removed an actor on the happy path would fill up with people who left hours ago.