fix: make callback setup() async

seriousme · seriousme · commit f5fc95db0469 · 2025-06-27T23:08:10.000+02:00
diff --git a/callBackPersistence.js b/callBackPersistence.js
@@ -17,10 +17,6 @@ class CallBackPersistence extends EventEmitter {
   }
 
   set broker (broker) {
-    this.setup(broker)
-  }
-
-  setup (broker) {
     if (this.ready) {
       return
     }
@@ -35,6 +31,10 @@ class CallBackPersistence extends EventEmitter {
       })
   }
 
+  setup (broker) {
+    return this.asyncPersistence.setup(broker)
+  }
+
   subscriptionsByTopic (topic, cb) {
     if (cb) {
       if (!this.ready) {

Original file line number	Diff line number	Diff line change
`@@ -17,10 +17,6 @@ class CallBackPersistence extends EventEmitter {`
`17`	`17`	`}`
`18`	`18`
`19`	`19`	`set broker (broker) {`
`20`		`- this.setup(broker)`
`21`		`- }`
`22`		`-`
`23`		`- setup (broker) {`
`24`	`20`	`if (this.ready) {`
`25`	`21`	`return`
`26`	`22`	`}`
`@@ -35,6 +31,10 @@ class CallBackPersistence extends EventEmitter {`
`35`	`31`	`})`
`36`	`32`	`}`
`37`	`33`
	`34`	`+ setup (broker) {`
	`35`	`+ return this.asyncPersistence.setup(broker)`
	`36`	`+ }`
	`37`	`+`
`38`	`38`	`subscriptionsByTopic (topic, cb) {`
`39`	`39`	`if (cb) {`
`40`	`40`	`if (!this.ready) {`