Struct SqliteSubscription 

pub struct SqliteSubscription {
    pub start: StartFrom<SqliteCursor>,
    pub filter: EventFilter,
    pub batch_size: Option<usize>,
    pub limit: Option<usize>,
}

Fields

start: StartFrom<SqliteCursor>

filter: EventFilter

batch_size: Option<usize>

limit: Option<usize>

Trait Implementations

impl Clone for SqliteSubscription

fn clone(&self) -> SqliteSubscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteSubscription

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

Formats the value using the given formatter.

impl Default for SqliteSubscription

fn default() -> Self

Returns the “default value” for a type.

impl StartableSubscription<SqliteCursor> for SqliteSubscription

fn with_start(self, start: StartFrom<SqliteCursor>) -> Self

fn with_starts(self, starts: Vec<StartFrom<C>>) -> Self

where C: Ord,

Seed this subscription with a collection of candidate start positions. Default behavior: pick the smallest StartFrom::After(c) from the vec and delegate to with_start. Other variants (Earliest, Latest, Timestamp) are ignored by the default impl — readers that support fan-in, dual historic+live consumption, or topology-aware resume must override.