0

我在 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"

任何想法 ？

4

0 回答 0