From 0df516c5498f5b857b85725629ad7c38d5d3c800 Mon Sep 17 00:00:00 2001 From: Brian C Date: Thu, 30 Jan 2014 23:07:03 -0600 Subject: [PATCH] Add cleanup to the example closes #2 --- README.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/README.md b/README.md index d16827a0..597538ed 100644 --- a/README.md +++ b/README.md @@ -34,6 +34,8 @@ pg.connect(function(err, client, done) { if(err) throw err; var query = new QueryStream('SELECT * FROM generate_series(0, $1) num', [1000000]) var stream = client.query(query) + //release the client when the stream is finished + stream.on('end', done) stream.pipe(JSONStream.stringify()).pipe(process.stdout) }) ```