configurable throttle

digidem · Oct 4, 2023 · 1a678d4 · 1a678d4
1 parent 02e02cc
commit 1a678d4
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/src/core-manager/replication-state.js b/src/core-manager/replication-state.js
@@ -6,10 +6,14 @@ import { throttle } from 'throttle-debounce'
 export class ReplicationState extends TypedEmitter {
   /** @type {Map<string, CoreReplicationState>} */
   #coreStates = new Map()
+  #handleUpdate
 
-  #handleUpdate = throttle(200, function () {
-    this.emit('state', this.getState())
-  }).bind(this)
+  constructor({ throttleMs = 200 } = {}) {
+    super()
+    this.#handleUpdate = throttle(throttleMs, function () {
+      this.emit('state', this.getState())
+    }).bind(this)
+  }
 
   getState() {
     const state = {