Node.js HTTP-Antwortstreams

Question

Mit dem nativen http.get() in Node.js versuche ich, eine HTTP-Antwort an einen Stream zu leiten, den ich an data und end Ereignisse binden kann.

Ich bin Umgang mit dieser derzeit für gzip Daten, mit:

http.get(url, function(res) { 
    if (res.headers['content-encoding'] == 'gzip') { 
    res.pipe(gunzip); 
    gunzip.on('data', dataCallback); 
    gunzip.on('end', endCallback); 
    } 
}); 

Gunzip ist ein Strom, und dies funktioniert einfach. Ich habe versucht, Streams zu erstellen (Streams zu schreiben, dann Streams zu lesen) und die Antwort zu pipen, hatte aber nicht viel Glück. Irgendwelche Vorschläge, um denselben Deal zu replizieren, für nicht gezippten Inhalt?

Answer 1

Das Antwortobjekt einer HTTP-Anfrage ist eine Instanz eines lesbaren Streams. Daher würden Sie die Daten mit dem Ereignis data sammeln und dann verwenden, wenn das Ereignis end ausgelöst wird.

var http = require('http'); 
var body = ''; 

http.get(url, function(res) { 
    res.on('data', function(chunk) { 
    body += chunk; 
    }); 
    res.on('end', function() { 
    // all data has been downloaded 
    }); 
}); 

Die readable.pipe(dest) tun würde im Grunde das Gleiche, wenn body in dem obigen Beispiel ein beschreibbarer Strom sind.