node.js - 如何刷新Twit流？ (Npm模块和Twitter API)

我想刷新Twit流。
我有一个使用npm模块Twit制作的Twitter流(您可以在这里找到它:https://github.com/ttezel/twit)。
这是我的代码:

Researches.find().observeChanges({
    added: function(){
        hashArray = Researches.find().fetch();
        hashCount = Researches.find().count();
        for(i=0; i<hashCount; i++){
            hashArray[i]= hashArray[i].hashtag;
        }
    }
});

stream = T.stream('statuses/filter', {track: hashArray});

//Launch stream
stream.on('tweet', Meteor.bindEnvironment(function(tweet) {
    //Get the hashtag of the tweet
    tweetText = tweet.text;
    tweetText = tweetText.toLowerCase();

    //Get the hashtag of the current tweet
    for(i=0; i<hashCount; i++){
        var hashCompare = hashArray[i];
        hashCompare = hashCompare.toLowerCase();
        var isInString = tweetText.search(hashCompare);
        if(isInString>=0)
            goodHash = hashArray[i];
    }

    // Get the tweet informations
    tweetToInsert = {
        user: tweet.user.screen_name,
        tweet: tweet.text,
        picture: tweet.user.profile_image_url,
        date: new Date().getTime(),
        hashtag: goodHash
    };

    matchTweet = Tweets.findOne({tweet:tweetToInsert.tweet});
    //Store tweets
    if(matchTweet || (lastTweet.user == tweetToInsert.user) || (lastTweet.tweet == tweetToInsert.tweet)){

    } else {
        console.log(tweetToInsert.tweet);
        Tweets.insert(tweetToInsert, function(error) {
            if(error)
                console.log(error);
        });
    }
    //Store last tweet
    lastTweet = {
        user: tweetToInsert.user,
        tweet: tweetToInsert.tweet
    }

    //Delete tweet overflow
    nbTweet = Tweets.find({hashtag: goodHash}).count();
    tweetToDelete = nbTweet-25;
    if(nbTweet>25){
        for(i=0; i<tweetToDelete;i++){
            idDelete = Tweets.findOne({hashtag: goodHash});
            Tweets.remove(idDelete._id);
        }
    }
}));

如您所见，我在自己的Researches Collection上进行了观察，并使用它对所有标签进行了数组排列。然后，我使用此数组来跟踪每个主题标签。
现在，这是我的问题。当我的收藏夹中有一个新的标签时，我的数组会使用新的标签更新自己，这很好。问题在于流不会自我更新。
我尝试过的
根据Twit文档，我尝试过.stop()流(这很好)，但是当我尝试使用.start()重新启动他时，它不起作用。
这是我尝试过的代码:

Researches.find().observeChanges({
    added: function(){
        hashArray = Researches.find().fetch();
        hashCount = Researches.find().count();
        for(i=0; i<hashCount; i++){
            hashArray[i]= hashArray[i].hashtag;
        }
        if(stream){
            stream.stop();
            stream.start();
        }
    }
});

因此，您知道每次将hashtag添加到集合时，如何刷新/更新Twit流或删除并创建新的Twit流。
谢谢

最佳答案

这个github问题和评论回答了您的问题:https://github.com/ttezel/twit/issues/90#issuecomment-41247402

基本上，刷新列表时，您需要创建第二个流并关闭第一个流。

var Twit = require('twit');
var twit = new Twit(config);
var stream1 = twit.stream('statuses/filter', { track: [ '#yolo' ] });

// ... some time passes ...

 // initiate a new streaming connection with our updated track list
var stream2 = twit.stream('statuses/filter', { track: [ '#yolo', '#fun' ] });

stream2.once('connected', function (res) {
    console.log('second stream connected')
    // stop the first stream ASAP so twitter doesn't block us
    stream1.stop();

    stream2.on('tweet', function (tweet) {
        // handle tweets
    });
});