0

我在这里看到了一些类似的问题,但似乎没有一个与此直接相关。我正在阅读 twitter 流并使用 socket.io 发出它,如下所示:

stream.on('data', function (data) {
            var geo=false,latitude,longitude;

      if(data.geo!=null){
          geo = true;
          latitude = data.geo.coordinates[0];
          longitude = data.geo.coordinates[1];

      }
      io.sockets.volatile.emit('tweets', {
          user: data.user.screen_name,
          text: data.text,
          geo : geo,
          latitude: latitude,
          longitude: longitude,
      });       
});

我想在它被发送到套接字之前添加一些数据处理。处理代码如下:

var sentiment;
sentiment(data.text, function (err, result) {
    sentiment = result.score;
});

我想将它发射为:

io.sockets.volatile.emit('tweets', {
              user: data.user.screen_name,
              text: data.text,
              geo : geo,
              latitude: latitude,
              longitude: longitude,
                  sentiment: sentiment
          }); 

但是我得到了我认为与处理的异步性质有关的错误。如何强制它在发射前等待处理功能完成?

4

1 回答 1

2

您正在覆盖您的sentiment功能:

var sentiment;                                <-- declare a var...
sentiment(data.text, function (err, result) { <-- ..and call it (which fails)
    sentiment = result.score; 
});
于 2013-06-11T14:50:19.287 回答