(expected = 1)
| 62 | }); |
| 63 | |
| 64 | const readRows = async (expected = 1) => { |
| 65 | let lines = []; |
| 66 | for (let i = 0; i < 150; i++) { |
| 67 | if (fs.existsSync(traceFile)) { |
| 68 | lines = fs.readFileSync(traceFile, 'utf8').trim().split('\n').filter(Boolean); |
| 69 | if (lines.length >= expected) break; |
| 70 | } |
| 71 | await sleep(20); |
| 72 | } |
| 73 | return lines.map((l) => JSON.parse(l)); |
| 74 | }; |
| 75 | |
| 76 | try { |
| 77 | await run({ call, readRows }); |
no test coverage detected