Struct StreamConfig 

pub struct StreamConfig {
    pub buffer_size: usize,
    pub timeout_secs: Option<u64>,
}

Configuration controlling backpressure and optional timeout for a QueryStream.

Fields

buffer_size: usize

Channel capacity — the maximum number of un-consumed Rows that can be buffered in memory. When the channel is full the producer blocks until the consumer drains at least one item. Defaults to 64.

timeout_secs: Option<u64>

Optional per-stream timeout in seconds. If set, the background task is automatically cancelled after this many seconds even if rows remain unread. None means no timeout.

Implementations

impl StreamConfig

pub fn new(buffer_size: usize) -> Self

Create a new config with the given buffer size.

pub fn with_timeout(self, secs: u64) -> Self

Set an optional timeout (seconds) after which the stream is cancelled.

Trait Implementations

impl Clone for StreamConfig

fn clone(&self) -> StreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamConfig

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

Formats the value using the given formatter.

impl Default for StreamConfig

fn default() -> Self

Returns the “default value” for a type.