( lines: ProcessLineResult[], hook: (data: any, lineNumber: number) => void | PromiseLike<void>, conv: Converter, offset: number, needPushDownstream: boolean, cb: (err?) => void, res: ProcessLineResult, )
| 140 | } |
| 141 | |
| 142 | function processRecursive( |
| 143 | lines: ProcessLineResult[], |
| 144 | hook: (data: any, lineNumber: number) => void | PromiseLike<void>, |
| 145 | conv: Converter, |
| 146 | offset: number, |
| 147 | needPushDownstream: boolean, |
| 148 | cb: (err?) => void, |
| 149 | res: ProcessLineResult, |
| 150 | ) { |
| 151 | if (needPushDownstream) { |
| 152 | pushDownstream(conv, res); |
| 153 | } |
| 154 | processLineByLine(lines, conv, offset, needPushDownstream, cb); |
| 155 | } |
| 156 | function pushDownstream(conv: Converter, res: ProcessLineResult) { |
| 157 | if (typeof res === "object" && !conv.options.objectMode) { |
| 158 | const data = JSON.stringify(res); |
no test coverage detected