From c9280e2b116c9c459127e9d759b4ef4b27dcd4cf Mon Sep 17 00:00:00 2001
From: "Richard T. Carback III" <rick.carback@gmail.com>
Date: Wed, 14 Jun 2023 18:40:08 +0000
Subject: [PATCH] Convert the ListenOn* funcs to be non-async
---
wasm/collective.go | 30 ++++++++++--------------------
1 file changed, 10 insertions(+), 20 deletions(-)
diff --git a/wasm/collective.go b/wasm/collective.go
index 7abdcbd7..e7202220 100644
--- a/wasm/collective.go
+++ b/wasm/collective.go
@@ -420,17 +420,12 @@ func (r *RemoteKV) ListenOnRemoteKey(_ js.Value, args []js.Value) any {
localEvents = args[3].Bool()
}
- promiseFn := func(resolve, reject func(args ...any) js.Value) {
- id, err := r.api.ListenOnRemoteKey(key, version, cb,
- localEvents)
- if err != nil {
- reject(exception.NewTrace(err))
- } else {
- resolve(id)
- }
+ id, err := r.api.ListenOnRemoteKey(key, version, cb,
+ localEvents)
+ if err != nil {
+ exception.ThrowTrace(err)
}
-
- return utils.CreatePromise(promiseFn)
+ return id
}
// ListenOnRemoteMap allows the caller to receive updates when the map or map
@@ -456,17 +451,12 @@ func (r *RemoteKV) ListenOnRemoteMap(_ js.Value, args []js.Value) any {
localEvents = args[3].Bool()
}
- promiseFn := func(resolve, reject func(args ...any) js.Value) {
- id, err := r.api.ListenOnRemoteMap(mapName, version, cb,
- localEvents)
- if err != nil {
- reject(exception.NewTrace(err))
- } else {
- resolve(id)
- }
+ id, err := r.api.ListenOnRemoteMap(mapName, version, cb,
+ localEvents)
+ if err != nil {
+ exception.ThrowTrace(err)
}
-
- return utils.CreatePromise(promiseFn)
+ return id
}
// GetAllRemoteKeyListeners returns a JSON list of { key: [id, id, id, ...] },
--
GitLab