Struct Reader 

pub struct Reader<T: Clone + Send> { /* private fields */ }

Owned, ergonomic handle over an erased BufferReader.

Returned by Consumer::subscribe. This is the “boxed lane”: one indirect call per recv, zero AimDB-added heap allocations per message. (The generic monomorphized Reader<T, B> fast lane remains dormant.)

Implementations

impl<T: Clone + Send> Reader<T>

pub fn new(inner: Box<dyn BufferReader<T> + Send>) -> Self

Wrap an erased reader in an ergonomic handle.

pub async fn recv(&mut self) -> Result<T, DbError>

Receive the next value, awaiting until one is available.

Allocation-free: wraps the erased reader’s poll_recv via core::future::poll_fn.

Behavior by Buffer Type

• SPMC Ring: Returns next value, or Lagged(n) if fell behind
• SingleLatest: Waits for value change, returns most recent
• Mailbox: Waits for slot value, takes and clears it

pub fn try_recv(&mut self) -> Result<T, DbError>

Non-blocking receive — returns immediately.

Returns Err(DbError::BufferEmpty) if no pending values.