Struct NetNotifiedQueue 

pub struct NetNotifiedQueue<T, C: MessageCodec> { /* private fields */ }

Type-safe message queue with async notification.

Receives raw bytes, deserializes them to type T, and queues them. Consumers can async wait for messages using recv() or poll with try_recv().

Design

• Uses RefCell for single-threaded runtime (no Mutex overhead)
• Waker-based notification wakes all waiting consumers
• Deserializes on receive (producer side) to fail fast on bad messages
• Pluggable codec via C: MessageCodec type parameter

Type Safety

The type T is baked in at compile time. Only messages that deserialize to T will be accepted. Invalid messages log an error and are dropped.

Implementations

impl<T, C: MessageCodec> NetNotifiedQueue<T, C>

pub fn new(endpoint: Endpoint, codec: C) -> Self

Create a new queue with the given endpoint and codec.

pub fn with_address(address: NetworkAddress, codec: C) -> Self

Create a new queue with a dynamically allocated endpoint.

Uses the provided address with a new random UID.

pub fn endpoint(&self) -> &Endpoint

Get the endpoint for this queue.

Senders use this endpoint to address messages to this queue.

pub fn try_recv(&self) -> Option<T>

Try to receive a message without blocking.

Returns None if no message is available.

pub fn is_empty(&self) -> bool

Check if the queue is empty.

pub fn len(&self) -> usize

Get the number of messages currently in the queue.

pub fn messages_received(&self) -> u64

Get the total number of messages received.

pub fn messages_dropped(&self) -> u64

Get the number of messages dropped due to deserialization errors.

pub fn close(&self)

Mark the queue as closed.

After closing, recv() will return None when the queue is empty instead of waiting for more messages.

pub fn is_closed(&self) -> bool

Check if the queue is closed.

impl<T: DeserializeOwned, C: MessageCodec> NetNotifiedQueue<T, C>

pub fn recv(&self) -> RecvFuture<'_, T, C>

Async receive - waits for a message.

Returns None if the queue is closed and empty.

Trait Implementations

impl<T: DeserializeOwned + 'static, C: MessageCodec> MessageReceiver for NetNotifiedQueue<T, C>

fn receive(&self, payload: &[u8])

Process an incoming message payload.

fn is_stream(&self) -> bool

Whether this receiver handles a stream of messages (default: true).