Function streamLines

test/e2e/run.mjs:65–95

(stream, sink)

        // Line-buffered streaming so prefixed lines stay intact across chunk boundaries.
        const streamLines = (stream, sink) => {
            let buffer = '';
            stream.on('data', (chunk) => {
                buffer += chunk.toString();
                const lines = buffer.split('\n');
                buffer = lines.pop();
                for (const line of lines) {
                    if (line === '') continue;

                    if (!line.startsWith('[')) {
                        if (!seenFirst) {
                            console.log(
                                `${colors.red('[fatal]')} test ${colors.yellow(
                                    `[${dir.name}]`,
                                )} did not call "initialize(import.meta.url)"!`,
                            );
                            worker.terminate();
                            return;
                        }
                        deferredOnSuccess.push(line);
                        continue;
                    }

                    seenFirst = true;
                    sink(`${prefix}${line}`);
                }
            });
            stream.on('end', () => {
                if (buffer !== '') sink(`${prefix}${buffer}`);
            });
        };

        streamLines(worker.stdout, (line) => console.log(line));
        streamLines(worker.stderr, (line) => console.error(line));