¿Cómo cerrar un flujo legible (antes de finalizar)?

ReadStream.destruir

Puede llamar al flujo de lectura .destruye la función en cualquier momento.

var fs = require('fs');

var readStream = fs.createReadStream('lines.txt');
readStream
    .on('data', function (chunk) {
        console.log(chunk);
        readStream.destroy();
    })
    .on('end', function () {
        // This may not been called since we are destroying the stream
        // the first time 'data' event is received
        console.log('All the data in the file has been read');
    })
    .on('close', function (err) {
        console.log('Stream has been destroyed and file has been closed');
    });

La función pública ReadStream.destroy no está documentada (Nodo.js v0. 12. 2) pero puedes echar un vistazo al código fuente en GitHub (Oct 5, 2012 commit ).

La función destroy marca internamente la instancia ReadStream como destruida y llama a la función close para liberar el archivo.

Puedes escuchar el evento close para saber exactamente cuándo el archivo está cerrado. El evento end no se disparará a menos que los datos se consuman por completo.

Tenga en cuenta que las funciones destroy (y close) son específicas de fs.ReadStream . No hay parte de la corriente genérica .legible "interfaz".

No se puede. No hay una forma documentada de cerrar/apagar/abortar/destruir un flujo genérico legible a partir del nodo 5.3.0. Esta es una limitación de la arquitectura de flujo de nodos.

Como han explicado otras respuestas aquí, hay hacks no documentados para implementaciones específicas de Legible proporcionadas por Node, como fs.ReadStream . Estas no son soluciones genéricas para cualquier Legible sin embargo.

Si alguien puede probar que estoy equivocado aquí, por favor hágalo. Me gustaría ser capaz de hacer lo que estoy diciendo es imposible, y estaría encantado de ser corregido.

EDITAR : Aquí estaba mi solución: implementar .destroy() para mi canalización a través de una serie compleja de llamadas unpipe(). Y después de toda esa complejidad, no funciona correctamente en todos los casos.

En la versión 4.*.* empujar un valor null en la secuencia activará una señal EOF.

Del nodejs docs

Si se pasa un valor que no sea null, el método push() agrega un trozo de datos a la cola para que los procesadores de flujo posteriores lo consuman. Si se pasa null, señala el final de la secuencia (EOF), después de lo cual no se pueden escribir más datos.

Esto funcionó para mí después de probar muchas otras opciones en esta página.

Hoy, en el Nodo 10

readableStream.destroy()

Es la forma oficial de cerrar un flujo legible

Véase https://nodejs.org/api/stream.html#stream_readable_destroy_error

Puede borrar y cerrar la corriente con yourstream.resume(), lo que volcará todo en la corriente y eventualmente la cerrará.

De los documentos oficiales :

Legible.resume ():

Return: this

Este método hará que el flujo legible reanude la emisión de eventos 'data'.

Este método cambiará la corriente al modo de flujo. Si no desea consumir los datos de un flujo, pero desea llegar a su evento 'fin', puede llama a stream.resume () para abrir el flujo de datos.

var readable = getReadableStreamSomehow();
readable.resume();
readable.on('end', () => {
  console.log('got to the end, but did not read anything');
});

Es una pregunta antigua, pero yo también estaba buscando la respuesta y encontré la mejor para mi implementación. Ambos eventos end y close se emiten así que creo que esta es la solución más limpia.

Esto hará el truco en el nodo 4.4.* (versión estable en el momento de escribir):

var input = fs.createReadStream('lines.txt');

input.on('data', function(data) {
   if (gotFirstLine) {
      this.end(); // Simple isn't it?
      console.log("Closed.");
   }
});

Para una explicación muy detallada ver: http://www.bennadel.com/blog/2692-you-have-to-explicitly-end-streams-after-pipes-break-in-node-js.htm

Este código aquí hará el truco muy bien:

function closeReadStream(stream) {
    if (!stream) return;
    if (stream.close) stream.close();
    else if (stream.destroy) stream.destroy();
}

WriteStream.end() es la forma de cerrar un WriteStream...

Este módulo destroy está destinado a garantizar que una secuencia se destruya, manejando diferentes API y Nodos.js bugs. Ahora mismo es una de las mejores opciones.