

@unittest.skipUnless(RUN_INDEXES, 'RUN_INDEXES is 0')
def test_stream_index(self):
    if (not self.is_2i_supported()):
        raise unittest.SkipTest('2I not supported')
    (bucket, o1, o2, o3, o4) = self._create_index_objects()
    keys = []
    for entries in bucket.stream_index('field1_bin', 'val1', 'val3'):
        keys.extend(entries)
    self.assertEqual(sorted([o1.key, o2.key, o3.key]), sorted(keys))

dataset/ETHPy150Open basho/riak-python-client/riak/tests/test_2i.py TwoITests.test_stream_index/original