Struct Filter 

pub struct Filter { /* private fields */ }

Implementations

impl Filter

pub fn new<P>(p: P) -> Filter

where P: Fn(&Exchange) -> bool + Send + Sync + 'static,

pub fn with_error<P, S>(p: P, msg: S) -> Filter

where P: Fn(&Exchange) -> bool + Send + Sync + 'static, S: Into<String>,

Create a filter with a custom rejection error message.

pub fn id(&self) -> &str

pub fn accepts(&self, exchange: &Exchange) -> bool

pub fn from_apl(apl: &str) -> Result<Filter, Error>

Build a filter from an APL (Allora Predicate Language) expression string (v1). See module docs for supported atoms & operators; returns Error::Serialization on structural issues. Unknown atom formats degrade to literal body equality.

pub fn from_apl_with_id(id: Option<String>, apl: &str) -> Result<Filter, Error>

Trait Implementations

impl Debug for Filter

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Processor for Filter

fn process<'life0, 'life1, 'async_trait>( &'life0 self, exchange: &'life1 mut Exchange, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Filter: 'async_trait,