Fix throttle behavior to write all changes at once

CHANGELOG.md

@@ -4,6 +4,9 @@ All notable changes to this project (after v6.1.0) should be documented in this
 The format is (mostly) based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [6.1.1] - 2022-06-03
+Change throttle behavior to write all modified keys after one delay instead of
+waiting the set amount of time between each key.
 
 ## [6.1.0] - 2021-10-17
 Thanks to [@smellman](https://github.com/smellman) for the TypeScript updates.

package.json

@@ -1,6 +1,6 @@
 {
   "name": "redux-persist",
-  "version": "6.1.0",
+  "version": "6.1.1",
   "description": "persist and rehydrate redux stores",
   "main": "lib/index.js",
   "module": "es/index.js",

src/createPersistoid.ts

@@ -28,7 +28,7 @@ export default function createPersistoid(config: PersistConfig<any>): Persistoid
   let lastState: KeyAccessState = {}
   const stagedState: KeyAccessState = {}
   const keysToProcess: string[] = []
-  let timeIterator: any = null
+  let writeTimeout: any = null
   let writePromise: Promise<any> | null = null
 
   const update = (state: KeyAccessState) => {
@@ -54,17 +54,15 @@ export default function createPersistoid(config: PersistConfig<any>): Persistoid
     })
 
     // start the time iterator if not running (read: throttle)
-    if (timeIterator === null) {
-      timeIterator = setInterval(processNextKey, throttle)
+    if (writeTimeout === null) {
+      writeTimeout = setTimeout(flush, throttle)
     }
 
     lastState = state
   }
 
   function processNextKey() {
     if (keysToProcess.length === 0) {
-      if (timeIterator) clearInterval(timeIterator)
-      timeIterator = null
       return
     }
 
@@ -123,10 +121,16 @@ export default function createPersistoid(config: PersistConfig<any>): Persistoid
     }
   }
 
-  const flush = () => {
+  function flush() {
     while (keysToProcess.length !== 0) {
       processNextKey()
     }
+
+    if (writeTimeout) {
+      clearTimeout(writeTimeout)
+      writeTimeout = null
+    }
+
     return writePromise || Promise.resolve()
   }