def list_streams(self, uid, token):
        """
        List available streams. Make sure AMQP clients are up & running.

        :param uid: User's uid.
        :param token: Token of the user.
        :return: List of ids.
        """
        database = self.client[uid]
        database.authenticate(uid, token)
        collection = database['data_streams']
        res = []
        for obj in collection.find():
            tmp = {'iden': str(obj['_id']), 'meta': obj['meta']}
            if self.cache not in str(obj['_id']):
                iden = str(obj['_id'])
                content = collection.find_one({'_id': bson.ObjectId(iden)})
                uri = content['uri']
                queue = content['queue']
                self.cache[iden] = StreamConsumer(uid, token, iden,
                                                  self.uri, str(uri),
                                                  str(queue))
                self.cache[iden].start()
            res.append(tmp)
        return res
dataset/ETHPy150Open tmetsch/suricate/suricate/data/streaming.py/AMQPClient.list_streams/swapped operands of `not in`