twitter.py 文件源码

def start_feeds(self, *, feeds = None):
        if self.reconnecting:
            await self.reconnect_ready.wait()
            return
        self.reconnecting = True
        await self.reconnect_ready.wait()
        self.reconnect_ready.clear()
        if feeds: self.feeds = feeds
        if self.stream: self.stream.disconnect()
        self.stream = tweepy.Stream(auth = clients.twitter_api.auth, listener = self)
        self.stream.filter(follow = set([id for feeds in self.feeds.values() for id in feeds]), **{"async" : "True"})
        self.bot.loop.call_later(120, self.reconnect_ready.set)
        self.reconnecting = False