Throw the error after emitting it to the stream

knex · Jun 4, 2018 · b6eb6d0 · b6eb6d0
1 parent 04055b5
commit b6eb6d0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/runner.js b/src/runner.js
@@ -94,6 +94,7 @@ assign(Runner.prototype, {
         return runner.client.stream(runner.connection, sql, stream, options)
       } catch (e) {
         stream.emit('error', e)
+        throw new Error(e);
       }
     })