elasticsearch-scroll-stream
Advanced tools
Comparing version 1.1.0 to 1.1.1
@@ -29,2 +29,3 @@ /** | ||
this._counter = 0; | ||
this._total = 0; | ||
this._forceClose = false; | ||
@@ -61,3 +62,3 @@ Readable.call(this, stream_opts); | ||
ref_results[entry] = hit[entry]; | ||
}) | ||
}); | ||
@@ -77,2 +78,3 @@ self.push(objectMode ? ref_results : JSON.stringify(ref_results)); | ||
self._counter = 0; | ||
self._total = response.hits.total; | ||
self._forceClose = false; | ||
@@ -79,0 +81,0 @@ self.push(null); |
{ | ||
"name": "elasticsearch-scroll-stream", | ||
"version": "1.1.0", | ||
"version": "1.1.1", | ||
"description": "Elasticsearch Scroll query results as a Stream", | ||
@@ -5,0 +5,0 @@ "repository": { |
@@ -18,2 +18,3 @@ | ||
In addition it exposes a `#close()` method to force the stream to stop sourcing from Elasticsearch. | ||
When the stream is done, it will contain an attribute `_total` that is the total number of matching documents, which can be useful if you forced the stream to stop. | ||
@@ -20,0 +21,0 @@ |
24302
466
239