NodeJS流 - 泄漏管道？

Question

我現在在做NodeJS流的很多工作。

我發現自己需要的一件事是'漏水管'。

與stream.PassThrough一樣，但只在（並且只有）它沒有發送它的地方纔會丟棄數據。

這樣的事情已經存在嗎？ （stream.Transform）有多少下游管道連接？

Answer 1

我最終與解決方案想出了：

LeakyTransform.prototype._transform = function(chunk, encoding, done) { 
    if (this._readableState.pipesCount > 0) { 
    this.push(chunk); 
    } 
    done(); 
} 

Answer 2

直通實現_transfrom如下：

PassThrough.prototype._transform = function(chunk, encoding, cb) { 
    cb(null, chunk); 
}; 

我認爲你需要可以這樣實現的：

Leak.prototype._transform = function(chunk, encoding, cb) { 
}; 

即無操作