Struct SessionEntry 

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

One session’s payload, and the signal that it has been established.

Implementations

impl<T: Clone, E: Clone> SessionEntry<T, E>

pub async fn wait_ready(&self) -> Established<T, E>

Waits until this session has been established, one way or the other.

Follows Notify’s race-free pattern: the notified future is created before the readiness check, so a notify_waiters() landing between the check and the await is not missed. The loop covers a spurious wake-up, which would otherwise return before the session existed.

pub fn outcome(&self) -> Option<Established<T, E>>

How establishing this session turned out, or None if it has not been attempted yet. Unlike wait_ready this does not wait for the answer.

pub fn publish(&self, outcome: Established<T, E>)

Publishes the outcome of establishing this session.

A failure is published rather than swallowed so that waiters fail with the reason the session was never established, instead of hanging.

Trait Implementations

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

fn default() -> Self

Returns the “default value” for a type.