

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)
    d.addCallback(verify)
    o._d = d
    return self

dataset/ETHPy150Open couchbase/couchbase-python-client/txcouchbase/tests/test_views.py TxViewsTests.testIncrementalRows/VarMisuse@98/130 `d`->`self`