

def test_query(self):
    db = asyncmongo.Client(pool_id='test_query', host='127.0.0.1', port=int(self.mongod_options[0][1]), dbname='test', mincached=3)

    def noop_callback(response, error):
        logging.info(response)
        loop = tornado.ioloop.IOLoop.instance()
        loop.add_timeout((time.time() + 0.1), loop.stop)
    before = self.get_open_cursors()
    db.foo.find({
        
    }, callback=noop_callback)
    tornado.ioloop.IOLoop.instance().start()
    db.foo.find({
        
    }, callback=noop_callback)
    tornado.ioloop.IOLoop.instance().start()
    after = self.get_open_cursors()
    assert (before == after), ('%d cursors left open (should be 0)' % (after - before))

dataset/ETHPy150Open bitly/asyncmongo/test/test_query.py QueryTest.test_query/original