Warum kann ich in einen lesbaren Stream pushen?

Question

Ich verwendete einen ähnlichen Code, bis ich die Methode 'setEncoding' entdeckte. Beim Refactoring des Codes kam diese Frage zu mir.

readable.push(chunk, 'base64') 
readable.push(null) 
readable.pipe(res) 

Schieben Sie nicht eine Form des Schreibens von Daten? Kann ich keine Daten in einen lesbaren Stream schreiben? Ich weiß, dass alle Daten geschrieben werden müssen (sonst wäre es null) und irgendwann gelesen (oder es wird nutzlos), aber ich dachte, Node würde das von uns abstrahieren.

Könnte jemand dies für mich klären? Danke

Answer 1

Dies kommt ins Spiel, wenn Sie einen neuen lesbaren Stream von Grund auf neu erstellen. Ein lesbarer Stream muss irgendwo beginnen und es muss eine Möglichkeit geben, Daten in diesen neuen Stream zu bekommen. Wenn Sie eine push() wie in Ihrer Frage ausführen, puffern Sie die Daten, bis sie gelesen werden. An diesem Punkt werden sie aus dem Stream entfernt und dann an das Ziel für den Verbrauch weitergeleitet. Der Verbraucher liest die Daten weiter, bis "Null" erreicht wird, was anzeigt, dass der Datenstrom fertig ist.

var stream = require('stream'); 
var readable = new stream.Readable(); // new empty stream.Readable 
readable.push('some data'); 
readable.push(null); // Done writing data 

die vollste Bild zu bekommen, wie Ströme arbeiten unter der Haube und die verschiedenen Arten von Streams, sollten Sie die Stream Handbook von Unterstapeln lesen. Das sollte alle Fragen beantworten, die Sie noch haben könnten.