[persisters] Clear queue

Author: jamesgpearce

src/common/array.ts

@@ -56,7 +56,7 @@ export const arrayFilter = <Value>(
   cb: (value: Value) => boolean,
 ): Value[] => array.filter(cb);
 
-export const arrayClear = <Value>(array: Value[], to?: number): Value[] =>
+export const arrayClear = <Value>(array: Value[] = [], to?: number): Value[] =>
   array.splice(0, to);
 
 export const arrayPush = <Value>(array: Value[], ...values: Value[]): number =>

src/persisters/index.ts

@@ -13,7 +13,7 @@ import type {
   PersisterStats,
   Persists as PersistsType,
 } from '../@types/persisters/index.d.ts';
-import {arrayPush, arrayShift} from '../common/array.ts';
+import {arrayClear, arrayPush, arrayShift} from '../common/array.ts';
 import {
   errorNew,
   ifNotUndefined,
@@ -257,7 +257,10 @@ export const createCustomPersister = <
 
   const getStore = (): Store => store;
 
-  const destroy = (): Persister<Persist> => stopAutoLoad().stopAutoSave();
+  const destroy = (): Persister<Persist> => {
+    arrayClear(mapGet(scheduleActions, scheduleId));
+    return stopAutoLoad().stopAutoSave();
+  };
 
   const getStats = (): PersisterStats => ({loads, saves});