Struct PredicateFilter 

pub struct PredicateFilter { /* private fields */ }

Pure post-fetch filter that accepts/rejects instruments via a closure.

Does not provide any slugs or query params: combine with source filters via the provider’s with_filters() or add_filter() methods.

Implementations

impl PredicateFilter

pub fn new<F: Fn(&InstrumentAny) -> bool + Send + Sync + 'static>( label: impl Into<String>, predicate: F, ) -> Self

Creates a new PredicateFilter with a label and closure predicate.

pub fn outcome(value: impl Into<String>) -> Self

Convenience: keep only instruments with a matching outcome value.

Only [InstrumentAny::BinaryOption] instruments are checked; all other variants are rejected.

pub fn not_expired(now_ns: UnixNanos) -> Self

Convenience: reject instruments past expiration.

The caller provides the current time as [UnixNanos] so the filter works correctly with both real-time and simulated (backtest) clocks. Only [InstrumentAny::BinaryOption] instruments are checked; non-binary variants are accepted.

Trait Implementations

impl Debug for PredicateFilter

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

Formats the value using the given formatter.

impl InstrumentFilter for PredicateFilter

fn accept(&self, instrument: &InstrumentAny) -> bool

Post-fetch predicate: only instruments where this returns true are kept. Default accepts all instruments. Override to refine results after fetching.

fn market_slugs(&self) -> Option<Vec<String>>

Market slugs for concurrent per-slug fetching via GET /markets?slug=.

fn event_slugs(&self) -> Option<Vec<String>>

Event slugs for fetching event containers via GET /events?slug=. Each event returns multiple markets.

fn query_params(&self) -> Option<GetGammaMarketsParams>

Gamma API query params for bulk filtered fetching.

fn event_queries(&self) -> Option<Vec<(String, GetGammaMarketsParams)>>

Event queries with client-side sorting and limiting of embedded markets.

fn event_params(&self) -> Option<GetGammaEventsParams>

Gamma events API query params for fetching events with full filtering.

fn search_params(&self) -> Option<GetSearchParams>

Public search API params for text-based instrument discovery.

fn accept_new_market(&self, new_market: &PolymarketNewMarket) -> bool

Pre-fetch gate for new market WS events: returns true if the market should proceed to Gamma HTTP fetch. Used when this filter is set as the dedicated new_market_filter in the data client config. Default accepts all new markets.