Struct SensoryIntakeQueue 

pub struct SensoryIntakeQueue { /* private fields */ }

Thread-safe queue of sensory payloads (FeagiByteContainer bytes). Any transport (ZMQ, WebSocket, SHM) pushes here; burst engine polls.

Implementations

impl SensoryIntakeQueue

pub fn new() -> Self

Create an empty queue.

pub fn push(&self, bytes: Vec<u8>)

Push a sensory payload (call from transport layer when data is received).

Payloads are queued in arrival order with bounded memory. If the queue reaches capacity, the oldest payload is dropped.

pub fn push_with_source(&self, bytes: Vec<u8>, source_id: Option<String>)

pub fn poll_next(&self) -> Option<SensoryPacket>

Take the next payload if any (called by burst engine each burst).

pub fn clear(&self)

Drop all queued sensory payloads.

Used by strict genome transitions to guarantee no stale pre-transition sensory data can be consumed after a new genome is loaded.

Trait Implementations

impl Default for SensoryIntakeQueue

fn default() -> SensoryIntakeQueue

Returns the “default value” for a type.