569
569
record = vf.get_record_stream([('a',)], 'unordered', True).next()
570
570
self.assertEqual(1234, record._manager._get_max_entries_per_source())
573
572
def test_insert_record_stream_reuses_blocks(self):
574
573
vf = self.make_test_vf(True, dir='source')
575
574
def grouped_stream(revision_ids, first_parents=()):