Struct ChannelMap 

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

Defines independently queued Channel instances under one name.

Supply an instance string for every publish, read, condition, and completion guard. Add the map definition once to crate::PersistenceSchema.

Implementations

impl<T> ChannelMap<T>

pub fn new(name: impl Into<String>) -> Self

Defines a Channel map with stable name.

pub fn publish( &self, context: &mut Context, instance: &str, value: T, ) -> HandlerResult<()>

where T: Value,

Stages one message for instance from the current invocation.

Errors

Returns a crate::HandlerError when value cannot be encoded.

pub fn size(&self, context: &Context, instance: &str) -> HandlerResult<usize>

Returns the invocation snapshot’s message count for instance.

pub fn map_size(&self, context: &Context) -> HandlerResult<usize>

Returns the number of non-empty instances visible to the current RPC.

pub fn all_instance_keys(&self, context: &Context) -> HandlerResult<Vec<String>>

Returns sorted decoded non-empty keys, including buffered publishes.

pub fn condition_results( &self, context: &Context, instance: &str, ) -> HandlerResult<Vec<T>>

where T: Value,

Decodes messages consumed by instance’s satisfied condition.

Errors

Returns a crate::HandlerError when a message cannot be decoded.

pub fn for_one(&self, instance: &str) -> Condition

Creates an instance condition that consumes exactly one message.

pub fn for_n(&self, instance: &str, count: usize) -> Condition

Creates an instance condition that consumes exactly count messages.

pub fn at_least(&self, instance: &str, count: usize) -> Condition

Creates an instance condition with an inclusive lower queue-size bound.

pub fn at_most(&self, instance: &str, count: usize) -> Condition

Creates an instance condition with an inclusive upper queue-size bound.

pub fn range( &self, instance: &str, at_least: Option<usize>, at_most: Option<usize>, ) -> Condition

Creates an instance condition with optional inclusive lower and upper bounds.

pub fn when_empty(&self, instance: &str) -> ChannelGuard

Creates a conditional-completion guard requiring instance to be empty.

Trait Implementations

impl<T> Clone for ChannelMap<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.