自己通過流不管數據

Question

我正在學習有關node.js流，因此我想寫我自己的自定義流模塊。以下是我目前所面對的：

index.js：

fs = require("fs") 
var module = require("./module") 
var ws = fs.createWriteStream("out.txt") 

fs.createReadStream("in.txt") 
    .pipe(module()) 
    .pipe(ws) 

module.js：

var Stream = require('stream').Stream; 

module.exports = function() { 
    var stream = new Stream(); 

    this.writable = true; 
    this.readable = true; 

    stream.write = function(data) { 
    console.log("write") 
    stream.emit("data", data) 
    } 

    stream.end = function() { 
    console.log("end") 
    stream.emit("end") 
    } 

    stream.destroy = function() { 
    console.log("destroy") 
    stream.emit("close") 
    } 

    return stream; 
} 

in.txt：

text 
text 
text 
text 
text 
text 
text 
text 
text 
text 

的問題是， out.txt是空的，並且stream.write函數從不被調用。爲什麼？如果我註釋掉我的中間管道都行得通！

Answer 1

代碼中存在一個可以輕鬆修復的錯誤。

在module.js變化：

this.writable = true; 
this.readable = true; 

到：

stream.writable = true; 
stream.readable = true; 

，它會工作。

此外，如果你想了解更多關於如何使用流，substack創建了一個很好的資源，形式爲stream handbook。