Update lib/actions/read.js

EmptyInfinity · jhorbulyk · web-flow · commit d32a361a28ef · 2022-03-01T18:14:12.000+02:00
Co-authored-by: Jacob Horbulyk &lt;jacob@elastic.io&gt;
diff --git a/lib/actions/read.js b/lib/actions/read.js
@@ -92,7 +92,7 @@ async function readCSV(msg, cfg) {
       } else {
         data = arrayToObj(chunk)
       }
-      if (emitBehavior === 'emitIndividually') {
+      if (emitBehavior === 'emitIndividually' || cfg.emitAll === false || cfg.emitAll === 'false') {
         parseStream.pause()
         await that.emit('data', messages.newMessageWithBody(data))
         parseStream.resume()

Original file line number	Diff line number	Diff line change
`@@ -92,7 +92,7 @@ async function readCSV(msg, cfg) {`
`92`	`92`	`} else {`
`93`	`93`	`data = arrayToObj(chunk)`
`94`	`94`	`}`
`95`		`- if (emitBehavior === 'emitIndividually') {`
	`95`	`+ if (emitBehavior === 'emitIndividually' \|\| cfg.emitAll === false \|\| cfg.emitAll === 'false') {`
`96`	`96`	`parseStream.pause()`
`97`	`97`	`await that.emit('data', messages.newMessageWithBody(data))`
`98`	`98`	`parseStream.resume()`