Struct ConsciousnessStream 

pub struct ConsciousnessStream {
    pub state: Arc<Mutex<StreamState>>,
    /* private fields */
}

Thread-safe wrapper

Fields

state: Arc<Mutex<StreamState>>

Implementations

impl ConsciousnessStream

pub fn start(config: &Config) -> Arc<Mutex<StreamState>>

Start the stream in a background thread. Sets the global stream state so recall can use it.

pub fn feed_query(state: &Arc<Mutex<StreamState>>, query_hash: u64)

Feed a query into the stream — triggers surprise if prediction was wrong.

pub fn format_internal(s: &StreamState) -> String

Internal format implementation (takes &StreamState reference).

pub fn format(state: &Arc<Mutex<StreamState>>) -> String

Get the current stream state as a formatted string.

pub fn format_snapshot(snapshot: &SharedSnapshot) -> String

Format a snapshot read via seqlock — no Mutex needed on the read path. Use this from the MCP tool or any other reader that wants lock-free access. Falls back to “stale data” if the writer is mid-update for more than SNAPSHOT_MAX_RETRIES iterations.