Ensure listen call connects

porsager · porsager · commit b4c4602de963 · 2019-11-27T14:11:37.000+01:00
diff --git a/lib/index.js b/lib/index.js
@@ -147,7 +147,7 @@ export default function Postgres(url, options) {
         ? reject(errors.connection('ENDED', options))
         : ready
           ? send(connection, query, xs, args)
-          : fetchArrayTypes().then(() => send(connection, query, xs, args)).catch(reject)
+          : fetchArrayTypes(connection).then(() => send(connection, query, xs, args)).catch(reject)
     })
 
     promise.stream = (fn) => (query.stream = fn, promise)
@@ -255,7 +255,7 @@ export default function Postgres(url, options) {
 
   function addTypes(instance, connection) {
     Object.assign(instance, {
-      notify: (channel, payload) => instance`select pg_notify(${ channel }, ${ String(payload) })`,
+      notify: (channel, payload) => instance`select pg_notify(${ channel }, ${ '' + payload })`,
       unsafe: (xs, args) => query(true, connection || getConnection(), xs, args),
       array,
       rows,
