Struct LiveFilter 

pub struct LiveFilter<Predicate> { /* private fields */ }

The filtering (read) half of a live_filter split: a SendPipe whose predicate is swapped live by the paired FilterControl. Clone is a single Arc bump — hand a clone to every subscriber.

Implementations

impl<Predicate> LiveFilter<Predicate>

pub fn snapshot(&self) -> Arc<Predicate>

Snapshot the current predicate (introspection).

impl<Id: Ord> LiveFilter<IdSet<Id>>

pub fn contains(&self, id: &Id) -> bool

Synchronous membership check — for a control-plane query that only asks “does id match” and never forwards the item onward (unlike the SendPipe form, which admits or rejects an item flowing through it).

Trait Implementations

impl<Predicate> Clone for LiveFilter<Predicate>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Item, Predicate> SendPipe for LiveFilter<Predicate>

where Predicate: SendPipe<In = Item, Out = Item> + Send + Sync + 'static, Item: Send + 'static,

type In = Item

Input the pipe consumes.

type Out = Item

Output the pipe produces.

type Err = <Predicate as SendPipe>::Err

Error the pipe can fail with — Send here so it can cross cores.

fn call( &self, input: Item, ) -> impl Future<Output = Result<Item, Predicate::Err>> + Send

Apply the pipe. The returned future IS Send.