From 341e80e9e576303495c263c1cb355ffde75a85ea Mon Sep 17 00:00:00 2001 From: Matthieu Sieben Date: Thu, 3 Dec 2020 12:38:04 +0100 Subject: [PATCH] reject parsing promise on stream error --- packages/pg-protocol/src/index.ts | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/packages/pg-protocol/src/index.ts b/packages/pg-protocol/src/index.ts index 00491ff7f..79fceba2d 100644 --- a/packages/pg-protocol/src/index.ts +++ b/packages/pg-protocol/src/index.ts @@ -5,7 +5,10 @@ import { Parser, MessageCallback } from './parser' export function parse(stream: NodeJS.ReadableStream, callback: MessageCallback): Promise { const parser = new Parser() stream.on('data', (buffer: Buffer) => parser.parse(buffer, callback)) - return new Promise((resolve) => stream.on('end', () => resolve())) + return new Promise((resolve, reject) => { + stream.on('end', () => resolve()) + stream.on('error', (err) => reject(err)) + }) } export { serialize, DatabaseError }