elasticsearch-scroll-stream
Advanced tools
Comparing version 1.3.3 to 1.3.4
const { Readable } = require('stream') | ||
const MAX_URL_LENGTH = 2000; | ||
/** | ||
@@ -56,3 +57,7 @@ * LibElasticsearchScrollStream | ||
if (this._total !== this._counter && !this._forceClose) { | ||
this._client.scroll({ scroll: this._options.scroll, scroll_id: body._scroll_id }, this.getMoreUntilDone) | ||
if (body._scroll_id.length > MAX_URL_LENGTH) { | ||
this._client.scroll({ body: { scroll: this._options.scroll, scroll_id: body._scroll_id } }, this.getMoreUntilDone) | ||
} else { | ||
this._client.scroll({ scroll: this._options.scroll, scroll_id: body._scroll_id }, this.getMoreUntilDone) | ||
} | ||
} else { | ||
@@ -59,0 +64,0 @@ // clearScroll for the current _scroll_id |
{ | ||
"name": "elasticsearch-scroll-stream", | ||
"version": "1.3.3", | ||
"version": "1.3.4", | ||
"description": "Elasticsearch Scroll query results as a Stream", | ||
@@ -5,0 +5,0 @@ "repository": { |
Sorry, the diff of this file is not supported yet
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
25419
507