From 61f98d9de8ab2ceaf62435db1f2603d9257e1798 Mon Sep 17 00:00:00 2001
From: ashmit-coder <ashmitjagtap2209@gmail.com>
Date: Wed, 6 Dec 2023 22:45:02 +0530
Subject: [PATCH] test commit

---
 .../test/pool-query-stream-close.ts           | 29 +++++++++++++++++++
 1 file changed, 29 insertions(+)
 create mode 100644 packages/pg-query-stream/test/pool-query-stream-close.ts

diff --git a/packages/pg-query-stream/test/pool-query-stream-close.ts b/packages/pg-query-stream/test/pool-query-stream-close.ts
new file mode 100644
index 000000000..7a36558d9
--- /dev/null
+++ b/packages/pg-query-stream/test/pool-query-stream-close.ts
@@ -0,0 +1,29 @@
+import helper from "./helper";
+import QueryStream from "../src";
+import pg from "pg";
+
+
+describe("Pool Query-Stream",  function() {
+    
+    it('releases pool connection after end of query stream', async function() {
+        const pool = new pg.Pool();
+        // const client  = await pool.connect();
+        const query = new QueryStream('SELECT NOW()');
+        const stream = pool.query(query);
+        
+        query.on('end',async(res)=>{
+            console.log('query stream ended');
+        });
+        
+        // bellow code raising error as stream .on is not a function
+        console.log(await stream); // this never gets resolved;
+        stream.on('end',async (res)=>{
+            console.log(res);
+            await pool.end();
+            console.log('stream ended');
+            await Promise.resolve();
+        })
+                
+    })
+    
+})