Struct UserSender 

pub struct UserSender<U> { /* private fields */ }

Cloneable handle to the bounded user lane.

Implementations

impl<U> UserSender<U>

pub async fn send(&self, item: U) -> Result<(), UserClosed<U>>

Enqueue a user message, awaiting capacity (backpressure).

The send linearizes at the ring-slot publish. If the consumer is dropped while this send is blocked on a full ring, teardown releases it with its payload — a blocked send never reports success for an item that was not enqueued.

Errors

Returns UserClosed carrying item if the consumer is gone — including when teardown releases a send blocked on a full ring.

pub fn try_send(&self, item: U) -> Result<(), TrySendError<U>>

Enqueue a user message without blocking.

Errors

TrySendError::Full if the lane is at capacity, TrySendError::Closed if the consumer is gone — each carrying item back.

pub fn anchor(&self) -> UserAnchor<U>

Derive a non-owning anchor from this sender (address-table endpoint). The anchor holds no liveness: the lane closes when the last counting UserSender drops even while anchors are held.

Trait Implementations

impl<U> Clone for UserSender<U>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<U> Drop for UserSender<U>

fn drop(&mut self)

Executes the destructor for this type.