Private
processRuns the task that processes queued operations in batches. This method runs continuously until the store is stopped, or the process is terminated.
A promise that resolves when the task is complete.
Private
queueA queue of operations to be processed in batch.
Private
runningWhether or not the batched processing is currently running.
{false}
Private
storeThe store to batch operations for.
Queues a put operation to be processed in batch.
An array of write operations to be performed.
A promise that resolves when the put operation is complete.
AsyncBatchedStore extends BaseStore to provide batched operations for list and put methods. It queues operations and processes them in batches for improved efficiency. This store is designed to run for the full duration of the process, or until
stop()
is called.