如何查詢NodeJS流'元數據'？

Question

我有一個程序與幾個變換幾個長管道。

例如

socket.pipe(ta).pipe(tb).pipe(tc); 
... 
tc.pipe(other_socket); 

向/從管道添加/讀取元數據的最佳方式是什麼？

例如：ta將數據包累積並分解成行。 tb需要在每行的前面添加基於始發IP地址（如果有的話）的數據。

tb如何從其輸入中獲得remoteAddress？

這裏似乎與原型遺傳有一些相似之處。即tb應該詢問ta（它缺乏財產），那麼ta應該詢問socket（它有屬性）。

我正在尋找從管道添加和讀取元數據的一般方法，因爲我有其他更復雜但相似的問題。

我目前正在通過使用由'meta和​​屬性對象組成的'對象流'來解決此問題。每個轉換必須做到​​，大多數只留下meta。這種解決方案很難看，尤其是因爲我必須創建一個看起來像net的新模塊xnet，但生成這些增強對象，而不是普通緩衝區或字符串。

（Haskellers可能會認識到這一點的解決方案作爲一個單子，在那裏我擡起大部分流的轉變我使用到「元」單子。我還在學習Haskell，所以這種觀察可能不正確。）

Answer 1

如果元數據是隻讀的管道執行的特定實例數據，那麼在創建單獨的管道，爲什麼不通過這個數據。例如：socket.pipe（新的Ta（地址））

就Haskell而言，它聽起來像一個Reader moand，其中Pipeline執行功能需要一個Reader，它可以完全滿足所有單個管道的元數據需求管道

Answer 2

可以使用pipe事件：

tb.on('pipe', function(ta) { 
    console.log('getting data from', ta.remoteAddress); 
});