Add failing test for destroying unsubmitted stream

Author: brianc

packages/pg-query-stream/test/close.js

@@ -61,7 +61,7 @@ helper('early close', function (client) {
   })
 
   it('can destroy stream while reading an error', function (done) {
-    var stream = new QueryStream('SELECT * from pg_sleep(1), basdfasdf;')
+    var stream = new QueryStream('SELECT * from  pg_sleep(1), basdfasdf;')
     client.query(stream)
     stream.on('data', () => done(new Error('stream should not have returned rows')))
     stream.once('error', () => {
@@ -70,4 +70,19 @@ helper('early close', function (client) {
       setTimeout(done, 100)
     })
   })
+
+  it('does not crash when destroying the stream immediately after calling read', function (done) {
+    var stream = new QueryStream('SELECT * from generate_series(0, 100), pg_sleep(1);')
+    client.query(stream)
+    stream.on('data', () => done(new Error('stream should not have returned rows')))
+    stream.destroy()
+    stream.on('close', done)
+  })
+
+  it('does not crash when destroying the stream before its submitted', function (done) {
+    var stream = new QueryStream('SELECT * from generate_series(0, 100), pg_sleep(1);')
+    stream.on('data', () => done(new Error('stream should not have returned rows')))
+    stream.destroy()
+    stream.on('close', done)
+  })
 })