Struct LedgerStreamConfig 

#[non_exhaustive]
pub struct LedgerStreamConfig {
    pub ledger_tip_poll_interval: Duration,
    pub list_page_limit: Option<u32>,
    pub base_retry_delay: Duration,
    pub max_retry_delay: Duration,
    pub retry_jitter: Duration,
    pub max_buffered_live_items: NonZeroUsize,
    /* private fields */
}

Polling, retry, buffering, and observability controls for stream_* operations.

Client-level timeouts bound individual RPCs, not the total duration of the stream. Finite list_* operations use the retry and observer controls in ListConfig.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

ledger_tip_poll_interval: Duration

Delay between polls when using Poll delivery. Must be non-zero.

list_page_limit: Option<u32>

Maximum items per internally built List request.

base_retry_delay: Duration

Delay before the first transient retry.

max_retry_delay: Duration

Maximum exponential portion of a retry delay.

retry_jitter: Duration

Maximum random jitter added to a retry delay.

max_buffered_live_items: NonZeroUsize

Maximum number of live subscription items buffered during gap replay before reconnecting.

Implementations

impl LedgerStreamConfig

pub fn with_observer( self, observer: impl Fn(LedgerStreamEvent) + Send + Sync + 'static, ) -> Self

Installs the synchronous stream observer, replacing any prior callback.

The callback must return quickly and not block; its panic propagates to the polling task.

Trait Implementations

impl Clone for LedgerStreamConfig

fn clone(&self) -> LedgerStreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LedgerStreamConfig

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

Formats the value using the given formatter.

impl Default for LedgerStreamConfig

fn default() -> Self

Returns the “default value” for a type.