无法销毁node.js中的Twitterstream

我正在尝试与Socket.io一起使用NPM twitter。 stream.destory()函数不起作用。

var util = require('util'); var twitter = require('twitter'); var twit = new twitter({ consumer_key: '', consumer_secret: '', access_token_key: '', access_token_secret: '' }); var currentTwitStream; hashtags = []; module.exports = function (io) { io.sockets.on('connection', function (socket) { console.log('A new user connected!'); socket.on('data', function(data){ hashtags.push('#' + data.hashtag); hashtags.forEach(function(entry) { console.log(entry); }); if(currentTwitStream) currentTwitStream.destroy(); twit.stream('statuses/filter',{track:hashtags.join(',')},function(stream){ currentTwitStream = stream; stream.on('data',function(data,err){ socket.emit(); console.log(data.text); }); }); }); }); }; 

我将不胜感激任何有关如何解决这个问题的反馈。

下面的代码工作为我摧毁stream。

 var clientSteam = {}; clientSteam = stream;// After your stream.on('data',function(data,err){ 

//现在消灭stream

 if (Object.keys(clientSteam).length != 0) setTimeout(closeStream, 1000); function closeStream(){ console.log('Closing stream...'); clientSteam.destroy(); }