diff --git a/lib/query.js b/lib/query.js index 3b41504..ff9bc2c 100644 --- a/lib/query.js +++ b/lib/query.js @@ -137,7 +137,7 @@ module.exports = class Query extends Readable { } _onvisit (m) { - if (m.status === 1) this.successes++ + if (m.status === 0) this.successes++ else this.errors++ this.inflight--