Javascript String nodejs stream implementation

Question

我需要一個將數據發送到字符串的nodejs流（http://nodejs.org/api/stream.html）實現。你認識一個人嗎？

爲了直接我試圖管道請求響應是這樣的： 請求（'http://google.com/doodle.png'）.pipe（fs.createWriteStream（'doodle.png'））

FROM https://github.com/mikeal/request

感謝

Answer 1

您可能會發現類Sink的pipette模塊中適合完成這個用例。使用，你可以寫：

var sink = new pipette.Sink(request(...)); 
sink.on('data', function(buffer) { 
    console.log(buffer.toString()); 
} 

Sink也處理從流回來合理正常的錯誤事件。詳細信息請參見https://github.com/Obvious/pipette#sink。

[編輯：因爲我意識到我使用了錯誤的事件名稱。]

Answer 2

它不會是很難寫出一個符合流接口的類;這裏是一個實現了非常基礎，而且似乎與你鏈接的請求模塊工作的一個例子：

var stream = require('stream'); 
var util = require('util'); 
var request = require('request'); 

function StringStream() { 
    stream.Stream.call(this); 
    this.writable = true; 
    this.buffer = ""; 
}; 
util.inherits(StringStream, stream.Stream); 

StringStream.prototype.write = function(data) { 
    if (data && data.length) 
    this.buffer += data.toString(); 
}; 

StringStream.prototype.end = function(data) { 
    this.write(data); 
    this.emit('end'); 
}; 

StringStream.prototype.toString = function() { 
    return this.buffer; 
}; 


var s = new StringStream(); 
s.on('end', function() { 
    console.log(this.toString()); 
}); 
request('http://google.com').pipe(s);