javascript - event-stream マップは pg Callback の外部では機能しますが、内部では機能しません

Question

pg コールバックのイベント ストリームに問題があります。この小さなコードでそれを減らすことができました：

var es = require('event-stream');
var pg = require('pg');

var ar = ['dd','dd','aa'];
var s1 = es.readArray(ar);
var s2 = es.readArray(ar);

var k1 = s1.pipe(es.map(function(i,cb){console.log(i);cb()}));

pg.connect("______my_string_____",function(err, client,pgdone) {
  var k2 = s2.pipe(es.map(function(i,cb){console.log(i);cb()}));
  console.log(err);
  pgdone();
})

そのコードを実行すると、期待どおり、k1 の割り当てによって配列が表示されます。しかし、k2 の割り当ては、同じコードであるため、何もしません。

sudo npm update ですべてを更新しました。ここに私の package.json があります

"JSONStream": "^0.10.0",
"async": "^0.9.0",
"codecov.io": "0.0.8",
"commander": "^2.7.1",
"debug": "^2.1.1",
"event-stream": "^3.3.0",
"express": "^4.12.3",
"fs": "0.0.2",
"istanbul": "^0.3.8",
"lru-cache": "^2.6.2",
"mkdirp": "^0.5.0",
"mocha-lcov-reporter": "0.0.2",
"nock": "^1.2.1",
"numeral": "^1.5.3",
"path": "^0.11.14",
"pg": "^4.3.0",
"plotly": "^1.0.2",
"progress": "^1.1.8",
"request": "^2.53.0",
"should": "^5.2.0"

何か案が ？