estoy implementando un flujo de transformación que está canalizado por el cursor de mangosta (que funciona como un flujo legible, (o tal vez es un flujo legible real))
const myTransform = new Transform({ readableObjectMode: true, writableObjectMode: true, transform(chunk: Document, encoding, callback) { this.push(chunk?.toObject() ?? null); // <- transforms data callback(); // <- calls callback }, }); MyMongooseModelWithHugeData.find() .cursor() .pipe(myTransform) .pipe(someWriteStream)Sí. Mi código actual funciona bien.
Pero descubrí que la callback de llamada dentro de la implementación de transform , recibe el segundo parámetro (que obviamente parece un estilo clásico de devolución de llamada asíncrona de nodejs).
Entonces, cambié mi código como se muestra a continuación y descubrí que también funciona bien ...
const myTransform = new Transform({ readableObjectMode: true, writableObjectMode: true, transform(chunk: Document, encoding, callback) { callback(null, chunk?.toObject() ?? null); // <- transforms data and calls callback. }, }); Y me sentí algo incómodo. He buscado en algunos blogs sobre la creación de Transform stream. Y todos los artículos que encontré decían lo mismo que tengo que usar this.push() y llamar a callback() . Pero ninguno de ellos mencionó siquiera el segundo parámetro de callback() .
Entonces, mi pregunta es:
this.push() y callback() al pasar el valor transformado?this.push en lugar de callback ?de la documentación de nodejs
Es posible que no se genere ningún resultado a partir de un fragmento determinado de datos de entrada.
La función de callback de llamada debe llamarse solo cuando el fragmento actual se haya consumido por completo. El primer argumento pasado a la callback de llamada debe ser un objeto de Error si se produjo un error al procesar la entrada o null en caso contrario. Si se pasa un segundo argumento a la callback de llamada, se reenviará al método transform.push() .
En otras palabras, los siguientes son equivalentes:
transform.prototype._transform = function(data, encoding, callback) { this.push(data); callback(); }; transform.prototype._transform = function(data, encoding, callback) { callback(null, data); };