Attempt to fix unhandled promise rejection (#23)

andywer · Jul 8, 2019 · ba944f3 · ba944f3
1 parent 4211959
commit ba944f3
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 2 deletions.
diff --git a/dist/index.d.ts b/dist/index.d.ts
@@ -38,6 +38,16 @@ export interface Options {
      * Timeout in ms after which to stop retrying and just fail. Defaults to 3000 ms.
      */
     retryTimeout?: number;
+    /**
+     * Custom function to control how the payload data is stringified on `.notify()`.
+     * Use together with the `serialize` option. Defaults to `JSON.parse`.
+     */
+    parse?: (serialized: string) => any;
+    /**
+     * Custom function to control how the payload data is stringified on `.notify()`.
+     * Use together with the `parse` option. Defaults to `JSON.stringify`.
+     */
+    serialize?: (data: any) => string;
 }
 export interface Subscriber {
     /** Emits events: "error", "notification" & "redirect" */

diff --git a/src/index.ts b/src/index.ts
@@ -102,8 +102,10 @@ function connect (connectionConfig: pg.ClientConfig | undefined, options: Option
           newClient.once("end", () => reject(Error("Connection ended.")))
           newClient.once("error", reject)
         })
-        await newClient.connect()
-        await connecting
+        await Promise.all([
+          newClient.connect(),
+          connecting
+        ])
         connectionLogger("PostgreSQL reconnection succeeded")
         return newClient
       } catch (error) {