Struct AsyncStreamingConfig 

pub struct AsyncStreamingConfig {
    pub chunk_size: usize,
    pub buffer_size: usize,
    pub concurrency: usize,
    pub enable_backpressure: bool,
    pub operation_timeout_ms: Option<u64>,
    pub max_chunks: Option<usize>,
    pub skip_chunks: usize,
}

Configuration for async streaming operations

Fields

chunk_size: usize

Size of each chunk in bytes (default: 64KB)

buffer_size: usize

Buffer size for I/O operations (default: 8KB)

concurrency: usize

Maximum concurrent operations (default: 4)

enable_backpressure: bool

Enable automatic backpressure handling

operation_timeout_ms: Option<u64>

Timeout for individual operations in milliseconds

max_chunks: Option<usize>

Maximum number of chunks to process (None for unlimited)

skip_chunks: usize

Skip the first N chunks

Implementations

impl AsyncStreamingConfig

pub fn new() -> Self

Create a new async streaming configuration with default values

pub fn chunk_size(self, size: usize) -> Self

Set the chunk size

pub fn buffer_size(self, size: usize) -> Self

Set the buffer size

pub fn concurrency(self, level: usize) -> Self

Set the concurrency level

pub fn enable_backpressure(self, enable: bool) -> Self

Enable or disable backpressure handling

pub fn timeout(self, timeoutms: u64) -> Self

Set operation timeout

pub fn max_chunks(self, max: usize) -> Self

Set maximum number of chunks to process

pub fn skip_chunks(self, skip: usize) -> Self

Set number of chunks to skip

Trait Implementations

impl Clone for AsyncStreamingConfig

fn clone(&self) -> AsyncStreamingConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AsyncStreamingConfig

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

Formats the value using the given formatter.

impl Default for AsyncStreamingConfig

fn default() -> Self

Returns the “default value” for a type.