def testIncrementalRows(self):
        d = defer.Deferred()
        cb = self.make_connection()
        o = cb.queryEx(RowsHandler, 'beer', 'brewery_beers')
        self.assertIsInstance(o, RowsHandler)

        def verify(unused):
            self.assertTrue(o.indexed_rows == 7000)
            self.assertEqual(o._rows_received, o.indexed_rows)

            ## Commented because we can't really verify this now,
            ## can we?
            #self.assertTrue(o._call_count > 1)

        d.addCallback(verify)
        o._d = d
        return d
dataset/ETHPy150Open couchbase/couchbase-python-client/txcouchbase/tests/test_views.py/TxViewsTests.testIncrementalRows/operator `>` -> `==`