Wie streame ich Antwort in Express

Question

Ich habe versucht, eine Express-App zu erhalten, um die Antwort als Stream zu senden.

var Readable = require('stream').Readable; 
var rs = Readable(); 


app.get('/report', function(req,res) { 

    res.statusCode = 200; 
    res.setHeader('Content-type', 'application/csv'); 
    res.setHeader('Access-Control-Allow-Origin', '*'); 

    // Header to force download 
    res.setHeader('Content-disposition', 'attachment; filename=Report.csv'); 


    rs.pipe(res); 

    rs.push("USERID,NAME,FBID,ACCOUNT,SUBSCRIPTION,PRICE,STATE,TIMEPERIOD\n"); 

    for (var i = 0; i < 10; i++) { 
     rs.push("23,John Doe,1234,500,SUBSCRIPITON,100,ACTIVE,30\n"); 
    } 

    rs.push(null); 
});  

Es tut Druck in der Konsole, wenn i "rs.pipe (res)" durch "rs.pipe (process.stdout)" ersetzen, sondern wie man es in Express App funktioniert.

Error: not implemented 
    at Readable._read (_stream_readable.js:465:22) 
    at Readable.read (_stream_readable.js:341:10) 
    at Readable.on (_stream_readable.js:720:14) 
    at Readable.pipe (_stream_readable.js:575:10) 
    at line "rs.pipe(res);" 

Answer 1

Sie brauchen keinen lesbaren Stream-Instanz benötigen, verwenden Sie nur res.write():

res.write("USERID,NAME,FBID,ACCOUNT,SUBSCRIPTION,PRICE,STATE,TIMEPERIOD\n"); 

for (var i = 0; i < 10; i++) { 
    res.write("23,John Doe,1234,500,SUBSCRIPITON,100,ACTIVE,30\n"); 
} 

res.end(); 

Das funktioniert, weil in Express, res auf Knoten eigenen http.serverResponse basiert, so dass es alle seine Methoden erbt (wie write).