Struct SnapshotThenStreamConfig 

pub struct SnapshotThenStreamConfig<TSnapshot, TPublication> {
    pub client: Client,
    pub channel: String,
    pub decode: Arc<dyn Fn(&[u8]) -> Result<TPublication> + Send + Sync>,
    pub fetch_snapshot: Arc<dyn Fn() -> BoxFuture<'static, Result<TSnapshot>> + Send + Sync>,
    pub read_publication: Arc<dyn Fn(TPublication) -> Vec<TPublication> + Send + Sync>,
    pub apply_snapshot: Arc<dyn Fn(TSnapshot, Vec<TPublication>) + Send + Sync>,
    pub apply_live_publications: Arc<dyn Fn(Vec<TPublication>) + Send + Sync>,
    pub max_buffered: usize,
    pub on_reconnect: Option<Arc<dyn Fn() + Send + Sync>>,
    pub on_snapshot_refresh: Option<Arc<dyn Fn() + Send + Sync>>,
    pub on_error: Option<SnapshotErrorFn>,
}

Configuration for SnapshotThenStream.

Fields

client: Client

channel: String

decode: Arc<dyn Fn(&[u8]) -> Result<TPublication> + Send + Sync>

fetch_snapshot: Arc<dyn Fn() -> BoxFuture<'static, Result<TSnapshot>> + Send + Sync>

read_publication: Arc<dyn Fn(TPublication) -> Vec<TPublication> + Send + Sync>

apply_snapshot: Arc<dyn Fn(TSnapshot, Vec<TPublication>) + Send + Sync>

apply_live_publications: Arc<dyn Fn(Vec<TPublication>) + Send + Sync>

max_buffered: usize

on_reconnect: Option<Arc<dyn Fn() + Send + Sync>>

on_snapshot_refresh: Option<Arc<dyn Fn() + Send + Sync>>

on_error: Option<SnapshotErrorFn>