elasticsearch-scroll-stream
Advanced tools
Comparing version 1.0.5 to 1.0.6
@@ -44,4 +44,5 @@ /** | ||
var objectMode = self._readableState.objectMode; | ||
results.hits.forEach(function(hit) { | ||
self.push(JSON.stringify(hit.fields)); | ||
self.push(objectMode ? hit.fields : JSON.stringify(hit.fields)); | ||
self._counter++; | ||
@@ -48,0 +49,0 @@ }); |
@@ -47,2 +47,3 @@ /** | ||
var objectMode = self._readableState.objectMode; | ||
response.hits.hits.forEach(function(hit) { | ||
@@ -61,3 +62,3 @@ var ref_results = {}; | ||
self.push(JSON.stringify(ref_results)); | ||
self.push(objectMode ? ref_results : JSON.stringify(ref_results)); | ||
self._counter++; | ||
@@ -64,0 +65,0 @@ }); |
{ | ||
"name": "elasticsearch-scroll-stream", | ||
"version": "1.0.5", | ||
"version": "1.0.6", | ||
"description": "Elasticsearch Scroll query results as a Stream", | ||
@@ -5,0 +5,0 @@ "repository": { |
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
22434
452