createBatcher

Function: createBatcher()

function createBatcher<TValue, TSelected>(
   fn, 
   initialOptions, 
selector?): SolidBatcher<TValue, TSelected>

function createBatcher<TValue, TSelected>(
   fn, 
   initialOptions, 
selector?): SolidBatcher<TValue, TSelected>

Defined in: batcher/createBatcher.ts:63

Creates a Solid-compatible Batcher instance for managing batches of items, exposing Solid signals for all stateful properties.

Features:

Batch processing of items using the provided fn function
Configurable batch size and wait time
Custom batch processing logic via getShouldExecute
Event callbacks for monitoring batch operations
All stateful properties (items, counts, etc.) are exposed as Solid signals for reactivity

The batcher collects items and processes them in batches based on:

Maximum batch size
Time-based batching (process after X milliseconds)
Custom batch processing logic via getShouldExecute

Example usage:

tsx

const batcher = createBatcher(
  (items) => {
    // Process batch of items
    console.log('Processing batch:', items);
  },
  {
    maxSize: 5,
    wait: 2000,
    onExecute: (batcher) => console.log('Batch executed'),
    getShouldExecute: (items) => items.length >= 3
  }
);

// Add items to batch
batcher.addItem('task1');
batcher.addItem('task2');

// Control the batcher
batcher.stop();  // Pause processing
batcher.start(); // Resume processing

// Access batcher state via signals
console.log('Items:', batcher.allItems());
console.log('Size:', batcher.size());
console.log('Is empty:', batcher.isEmpty());
console.log('Is running:', batcher.isRunning());
console.log('Batch count:', batcher.executionCount());
console.log('Item count:', batcher.totalItemsProcessed());

const batcher = createBatcher(
  (items) => {
    // Process batch of items
    console.log('Processing batch:', items);
  },
  {
    maxSize: 5,
    wait: 2000,
    onExecute: (batcher) => console.log('Batch executed'),
    getShouldExecute: (items) => items.length >= 3
  }
);

// Add items to batch
batcher.addItem('task1');
batcher.addItem('task2');

// Control the batcher
batcher.stop();  // Pause processing
batcher.start(); // Resume processing

// Access batcher state via signals
console.log('Items:', batcher.allItems());
console.log('Size:', batcher.size());
console.log('Is empty:', batcher.isEmpty());
console.log('Is running:', batcher.isRunning());
console.log('Batch count:', batcher.executionCount());
console.log('Item count:', batcher.totalItemsProcessed());