Comparing version 7.10.0 to 7.11.0
@@ -98,3 +98,9 @@ 'use strict'; | ||
this._run(this._refine(this.raw, options), 'all', null, callback); | ||
const selection = this.raw; | ||
if (options.chunks) { | ||
return this._chunks(selection, null, 'all', options, callback); | ||
} | ||
this._run(this._refine(selection, options), 'all', null, callback); | ||
} | ||
@@ -118,11 +124,13 @@ | ||
const diag = { criteria, options }; | ||
const selection = Criteria.select(criteria, this); | ||
if (options.chunks) { | ||
return this._chunks(criteria, options, callback); | ||
return this._chunks(selection, diag, 'query', options, callback); | ||
} | ||
const selection = Criteria.select(criteria, this); | ||
this._run(this._refine(selection, options), 'query', { criteria, options }, callback); | ||
this._run(this._refine(selection, options), 'query', diag, callback); | ||
} | ||
_chunks(criteria, options, callback) { | ||
_chunks(selection, diag, action, options, callback) { | ||
@@ -132,4 +140,2 @@ Hoek.assert(options.from === undefined && options.count === undefined, 'Cannot use chunks option with from or count'); | ||
const selection = Criteria.select(criteria, this); | ||
const settings = Hoek.clone(options); | ||
@@ -168,3 +174,3 @@ delete settings.chunks; | ||
this._run(this._refine(selection, settings), 'query', { criteria, options }, step); | ||
this._run(this._refine(selection, settings), action, diag, step); | ||
}; | ||
@@ -171,0 +177,0 @@ |
{ | ||
"name": "penseur", | ||
"description": "Lightweight RethinkDB wrapper", | ||
"version": "7.10.0", | ||
"version": "7.11.0", | ||
"author": "Eran Hammer <eran@hammer.io> (http://hueniverse.com)", | ||
@@ -6,0 +6,0 @@ "repository": "git://github.com/hueniverse/penseur", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
72538
1653