Update lib/actions/read.js

EmptyInfinity · jhorbulyk · web-flow · commit 8bcedaa2dcc0 · 2022-03-01T18:14:06.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
@@ -118,7 +118,7 @@ async function readCSV(msg, cfg) {
     return
   }
 
-  if (emitBehavior === 'fetchAll') {
+  if (emitBehavior === 'fetchAll' || cfg.emitAll === true || cfg.emitAll === 'true') {
     await this.emit('data', messages.newMessageWithBody({ result }))
   } else if (emitBehavior === 'emitBatch') {
     const chunks = sliceIntoChunks(result, body.batchSize);

Original file line number	Diff line number	Diff line change
`@@ -118,7 +118,7 @@ async function readCSV(msg, cfg) {`
`118`	`118`	`return`
`119`	`119`	`}`
`120`	`120`
`121`		`- if (emitBehavior === 'fetchAll') {`
	`121`	`+ if (emitBehavior === 'fetchAll' \|\| cfg.emitAll === true \|\| cfg.emitAll === 'true') {`
`122`	`122`	`await this.emit('data', messages.newMessageWithBody({ result }))`
`123`	`123`	`} else if (emitBehavior === 'emitBatch') {`
`124`	`124`	`const chunks = sliceIntoChunks(result, body.batchSize);`