Struct MapOptions 

pub struct MapOptions { /* private fields */ }

Configure map operation behavior including batching.

Control how items in a collection are processed. By default, all items execute concurrently in a single batch. Set batch_size to limit concurrency — each batch completes before the next begins.

Examples

use durable_lambda_core::types::MapOptions;

// Default: all items concurrent.
let opts = MapOptions::new();

// Process in batches of 10.
let opts = MapOptions::new().batch_size(10);

Implementations

impl MapOptions

pub fn new() -> MapOptions

Create a new MapOptions with default settings (all items concurrent).

Examples

use durable_lambda_core::types::MapOptions;

let opts = MapOptions::new();

pub fn batch_size(self, size: usize) -> MapOptions

Set the maximum number of items to process concurrently per batch.

Each batch of items executes concurrently, but batches themselves run sequentially — the next batch starts only after the previous batch completes. Must be a positive value.

Panics

Panics if size is 0.

Examples

use durable_lambda_core::types::MapOptions;

let opts = MapOptions::new().batch_size(5);

pub fn get_batch_size(&self) -> Option<usize>

Return the configured batch size, if any.

Examples

use durable_lambda_core::types::MapOptions;

let opts = MapOptions::new();
assert_eq!(opts.get_batch_size(), None);

let opts = MapOptions::new().batch_size(10);
assert_eq!(opts.get_batch_size(), Some(10));

Trait Implementations

impl Clone for MapOptions

fn clone(&self) -> MapOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MapOptions

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

Formats the value using the given formatter.

impl Default for MapOptions

fn default() -> MapOptions

Returns the “default value” for a type.