Struct SessionRegistry 

pub struct SessionRegistry<T, E = SessionError> { /* private fields */ }

The sessions an engine is serving, keyed by the id the SDK gave them.

Implementations

impl<T: Clone, E: Clone + From<SessionError>> SessionRegistry<T, E>

pub async fn resolve(&self, id: Uuid) -> Established<T, E>

The payload a request runs against, waiting for the session to be registered if its lifecycle event has not been applied yet.

pub fn entry(&self, id: Uuid) -> Arc<SessionEntry<T, E>>

The entry a lifecycle event publishes into, creating it if a request is not already waiting on one.

pub fn established(&self, id: Uuid) -> Option<Established<T, E>>

How a session stands right now, without waiting for one or registering one.

This is what work that cannot wait resolves against — delivering a notification, say, which has nowhere to go if its session is gone.

pub fn end(&self, id: Uuid) -> Option<Established<T, E>>

Ends a session, failing anything waiting on it.

The failure is published before the session is forgotten, so a request that outlived the handle it was made from fails rather than waiting for a session that has just gone away.

pub fn close(&self)

Fails every session that has not been established, and every one asked for from now on, because no further lifecycle event can arrive.

Trait Implementations

impl<T, E> Default for SessionRegistry<T, E>

fn default() -> Self

Returns the “default value” for a type.