構造Node.js中的兩個變換流

Question

我有一個無操作變換流測試，輸出通過它傳遞的所有文件的列表。爲什麼下面的代碼只輸出一次文件列表？如何正確組合兩個流？

var composed = test().pipe(test()); 
gulp.src('source/*').pipe(composed); 

Answer 1

要撰寫流，你pipe()第一至第二，但你也必須修改pipe()和unpipe()使它們適用於第二流。通過這種方式，合成流上pipe()的其他調用將使用第二個流的輸出而不是第一個流。

function compose(s1, s2) { 
    s1.pipe(s2); 
    s1.pipe = function (dest) { 
     return s2.pipe(dest); 
    } 
    s1.unpipe = function (dest) { 
     return s2.unpipe(dest); 
    } 
    return s1; 
} 

var composed = compose(test(), test()); 
gulp.src('source/*') 
    .pipe(composed) // src -> s1 -> s2 
    .pipe(...);  // s2 -> ... 

Answer 2

pipe()返回流被管道輸送到，不從（以允許鏈接）。所以第二行基本上是試圖管到test()的第二個實例。你需要做的，而不是什麼是：

var first = test(); 
first.pipe(test()); 
gulp.src('source/*').pipe(first); 

或者：

gulp.src('source/*') 
    .pipe(test()) 
    .pipe(test());