Struct MemoriesWatcher 

pub struct MemoriesWatcher { /* private fields */ }

Reactive filter over MemoriesState. Created via super::MemoriesAdapter::watch.

Implementations

impl MemoriesWatcher

pub fn where_id_in(self, ids: impl IntoIterator<Item = u64>) -> MemoriesWatcher

Restrict to memories whose id is in the provided collection.

pub fn where_source(self, source: impl Into<String>) -> MemoriesWatcher

Restrict to memories from this source.

pub fn content_contains(self, needle: impl Into<String>) -> MemoriesWatcher

Restrict to memories whose content contains needle (case-insensitive).

pub fn where_tag(self, tag: impl Into<String>) -> MemoriesWatcher

Restrict to memories tagged with tag.

pub fn where_any_tag( self, tags: impl IntoIterator<Item = String>, ) -> MemoriesWatcher

Restrict to memories that have AT LEAST ONE of the given tags.

pub fn where_all_tags( self, tags: impl IntoIterator<Item = String>, ) -> MemoriesWatcher

Restrict to memories that have EVERY tag in the given set.

pub fn where_pinned(self, pinned: bool) -> MemoriesWatcher

Restrict to pinned (true) or unpinned (false) only.

pub fn created_after(self, ns: u64) -> MemoriesWatcher

Restrict to created_ns >= ns (inclusive).

pub fn created_before(self, ns: u64) -> MemoriesWatcher

Restrict to created_ns <= ns (inclusive).

pub fn updated_after(self, ns: u64) -> MemoriesWatcher

Restrict to updated_ns >= ns (inclusive).

pub fn updated_before(self, ns: u64) -> MemoriesWatcher

Restrict to updated_ns <= ns (inclusive).

pub fn order_by(self, order: OrderBy) -> MemoriesWatcher

Order each emitted result set.

pub fn limit(self, n: usize) -> MemoriesWatcher

Truncate each emitted result set to n after ordering.

pub fn stream(self) -> impl Stream<Item = Vec<Arc<Memory>>> + Send + 'static

Start emitting. The stream yields:

• The current filter result immediately (first element).
• A new result vector on each subsequent fold tick where the filter’s result differs from the previously emitted one.

Backing channel is single-slot: if the consumer falls behind a fast fold task, intermediate filter results are dropped and the consumer sees the latest state on the next poll. Same “drop intermediate, final state is correct” semantic as crate::adapter::net::cortex::CortexAdapter::changes.

If order_by was not set, the watcher defaults to IdAsc so Vec-equality dedup is deterministic — otherwise HashMap iteration order could produce spurious re-emissions.

The stream ends when the adapter’s change stream ends (e.g. when all adapter handles drop and the fold task exits).