Struct LocalNotify 

pub struct LocalNotify { /* private fields */ }

Single-threaded notification with per-token dedup.

Mirrors event_queue semantics for single-threaded use. Tokens are registered, marked as changed, and polled. Each token appears at most once per poll cycle.

The interest/subscription layer (mapping data sources to reactors) is a higher-level concern handled by the consumer (e.g., the reactor system in nexus-rt).

Implementations

impl LocalNotify

pub fn with_capacity(capacity: usize) -> Self

Create with an initial capacity hint. Grows as needed.

pub fn register(&mut self) -> Token

Register a new token. Returns its identifier.

Grows the dedup bitset if needed.

pub fn ensure_capacity(&mut self, idx: usize)

Ensure the bitset can hold a token at the given index.

Use this when token indices are managed externally (e.g., by a slab) and may not be sequential. Grows the bitset and updates the high-water mark if needed.

pub fn mark(&mut self, token: Token)

Mark a token as changed this cycle.

If the token is already marked (deduped), this is a no-op.

Panics

Panics if token.index() >= num_tokens (unregistered token).

pub fn poll(&mut self, events: &mut Events)

Drain all marked tokens into the events buffer.

The events buffer is cleared then filled. Tokens appear in mark order. After polling, all dedup state is cleared — ready for the next cycle.

Mirrors Poller::poll.

pub fn poll_limit(&mut self, events: &mut Events, limit: usize)

Drain up to limit marked tokens into the events buffer.

Remaining tokens stay queued for the next poll call. Tokens appear in mark order (FIFO).

Mirrors Poller::poll_limit.

pub fn has_notified(&self) -> bool

Returns true if any token is marked.

pub fn notified_count(&self) -> usize

Number of tokens currently marked.

pub fn capacity(&self) -> usize

Number of registered tokens.

Trait Implementations

impl Debug for LocalNotify

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.