我在这里看到了一些类似的问题,但似乎没有一个与此直接相关。我正在阅读 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
});
但是我得到了我认为与处理的异步性质有关的错误。如何强制它在发射前等待处理功能完成?