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
评论列表
文章目录