Node.js
Procesamiento incremental de datos con streams Readable, Writable, Duplex y Transform, incluyendo piping, backpressure, errores y consumo eficiente de memoria.
Un stream procesa datos por chunks y regula la diferencia de velocidad entre productor y consumidor.
productor rápido
↓
buffer interno
↓
consumidor lento
↓
backpressure regula el flujoimport { createReadStream, createWriteStream } from "node:fs";
import { pipeline } from "node:stream/promises";
import { createGzip } from "node:zlib";
await pipeline(
createReadStream("report.csv"),
createGzip(),
createWriteStream("report.csv.gz")
);pipeline propaga errores y coordina cierre mejor que encadenar pipe sin manejo.
if (!writable.write(chunk)) {
await once(writable, "drain");
}Cuando write() retorna false, el buffer interno alcanzó su umbral. El productor debe esperar drain.
Es un umbral de buffering, no un límite rígido universal de memoria. Ajustarlo cambia throughput y memoria; mídelo con la carga real.
Un readable puede empujar datos automáticamente (data) o ser consumido de forma controlada.
for await (const chunk of readable) {
await processChunk(chunk);
}La iteración asíncrona expresa espera y errores con claridad.
En object mode cada chunk es un valor JavaScript, no bytes. El highWaterMark cuenta objetos y una sola entrada puede ser grande.
await pipeline(source, transform, destination, { signal });Abortar debe cerrar recursos y detener productores. Maneja archivos parciales cuando el destino persiste datos.
finished(stream) permite esperar finalización o error de un stream individual.
Node incluye interoperabilidad creciente con Web Streams. Verifica estabilidad y conversiones en la versión objetivo; no mezcles ambos modelos sin comprender cancelación y backpressure.
data y hacer trabajo async ilimitado.write.pipe sin estrategia de errores.pipeline para cerrar recursos.pipeline coordina errores y cleanup.¿Por qué una línea de texto puede llegar dividida entre dos chunks?
Porque el stream entrega fragmentos según buffers y disponibilidad, no según la estructura lógica del contenido.
Timers y scheduling explica cómo programar oportunidades futuras sin confundirlas con ejecución exacta.