Как тестировать Streams в Node.js?

Для readable streams: собирай chunks в массив через for await (const chunk of stream). Для writable: создавай writable in-memory (passthrough или buffer collect). const chunks = []; stream.on("data", chunk => chunks.push(chunk)); await new Promise(resolve => stream.on("end", resolve)); const result = Buffer.concat(chunks). Для transform streams: pipe source через transform в collect destination. stream.pipeline промисифицированный для удобства. Мокируй источники данных создавая Readable.from(array).