Wie kann ich einen rohen Stream in Node.js "akkumulieren"?

Question

Im Moment habe ich alles in einen String verketten als

var body = ''; 
res.on('data', function(chunk){ 
    body += chunk; 
}); 

folgt Wie kann ich den rohen Strom erhalten und zu sammeln, damit ich rohe Bytes an Funktionen übergeben können, die Bytes und nicht String erwarten?

Answer 1

Zunächst, überprüfen Sie, dass diese Funktionen eigentlich die Bytes alle auf einmal benötigen. Sie sollten wirklich 'data' Ereignisse akzeptieren, so dass Sie einfach die Puffer in der Reihenfolge weitergeben können, in der Sie sie erhalten.

Wie auch immer, hier ist ein Brute-Force-Weg, um alle Datenblock Puffer ohne Decodierung sie verketten:

var bodyparts = []; 
var bodylength = 0; 
res.on('data', function(chunk){ 
    bodyparts.push(chunk); 
    bodylength += chunk.length; 
}); 
res.on('end', function(){ 
    var body = new Buffer(bodylength); 
    var bodyPos=0; 
    for (var i=0; i < bodyparts.length; i++) { 
     bodyparts[i].copy(body, bodyPos, 0, bodyparts[i].length); 
     bodyPos += bodyparts[i].length; 
    } 
    doStuffWith(body); // yay 
}); 

Answer 2

Bessere Nutzung Buffer.concat - viel einfacher. Verfügbar in Knoten v0.8 +.

var chunks = []; 
res.on('data', function(chunk) { chunks.push(chunk); }); 
res.on('end', function() { 
    var body = Buffer.concat(chunks); 
    // Do work with body. 
}); 

Answer 3

Alternativ können Sie auch eine node.js Bibliothek wie bl oder Concat-Stream verwenden:

'use strict' 
let http = require('http') 
let bl = require('bl') 
http.get(url, function (response) { 
    response.pipe(bl(function (err, data) { 
    if (err) 
     return console.error(err) 
    console.log(data) 
    })) 
})