(data: any, raw: any)
| 52 | } |
| 53 | |
| 54 | function writeJson(data: any, raw: any) { |
| 55 | const writer = new HTTPJSONWriteStream(raw); |
| 56 | writer.preStart(); |
| 57 | |
| 58 | for (let index = 0; index < data.length; index++) { |
| 59 | const element = data[index]; |
| 60 | applyFunctionToResultSync(element, (x) => { |
| 61 | return writer.push(x); |
| 62 | }); |
| 63 | } |
| 64 | writer.end(); |
| 65 | } |
| 66 | |
| 67 | async function writeCsvStreamed(inputFilePath: any, raw: any, streamFn: any) { |
| 68 | const writer = new HTTPCSVWriteStream(raw); |
nothing calls this directly
no test coverage detected