postgres - npm Package Compare versions

Comparing version 3.3.0 to 3.3.1

cjs/src/index.js

@@ -174,13 +174,12 @@ const os = require('os')
       channels[name].listeners.push(listener)
+      const result = await channels[name].result
       listener.onlisten && listener.onlisten()
-      return Promise.resolve({ ...channels[name].result, unlisten })
+      return { state: result.state, unlisten }
     }
 
-    const result = await sql`listen ${ sql(name) }`
-    channels[name] = { result, listeners: [listener] }
+    channels[name] = { result: sql`listen ${ sql(name) }`, listeners: [listener] }
+    const result = await channels[name].result
     listener.onlisten && listener.onlisten()
-    result.unlisten = unlisten
+    return { state: result.state, unlisten }
 
-    return result
-
     async function unlisten() {
@@ -187,0 +186,0 @@ if (name in channels === false)

package.json

 {
   "name": "postgres",
-  "version": "3.3.0",
+  "version": "3.3.1",
   "description": "Fastest full featured PostgreSQL client for Node.js",
@@ -5,0 +5,0 @@ "type": "module",

src/index.js

@@ -174,13 +174,12 @@ import os from 'os'
       channels[name].listeners.push(listener)
+      const result = await channels[name].result
       listener.onlisten && listener.onlisten()
-      return Promise.resolve({ ...channels[name].result, unlisten })
+      return { state: result.state, unlisten }
     }
 
-    const result = await sql`listen ${ sql(name) }`
-    channels[name] = { result, listeners: [listener] }
+    channels[name] = { result: sql`listen ${ sql(name) }`, listeners: [listener] }
+    const result = await channels[name].result
     listener.onlisten && listener.onlisten()
-    result.unlisten = unlisten
+    return { state: result.state, unlisten }
 
-    return result
-
     async function unlisten() {
@@ -187,0 +186,0 @@ if (name in channels === false)

No alert changes

Improved metrics

Total package byte prevSize

205564

increased by0.04%

No dependency changes