From 6bbd0c7301e078de450993e97bc8698fb48da9cc Mon Sep 17 00:00:00 2001 From: Piotr Jastrzebski Date: Fri, 19 Jan 2018 19:47:05 +0100 Subject: [PATCH] test_reading_from_random_partial_partition: use flat reader Signed-off-by: Piotr Jastrzebski --- tests/row_cache_test.cc | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/tests/row_cache_test.cc b/tests/row_cache_test.cc index 423f79441a..69f3a394ca 100644 --- a/tests/row_cache_test.cc +++ b/tests/row_cache_test.cc @@ -643,19 +643,19 @@ SEASTAR_TEST_CASE(test_reading_from_random_partial_partition) { cache.populate(m1); // m1 is supposed to have random continuity and populate() should preserve it - auto rd1 = cache.make_reader(gen.schema()); - auto sm1 = rd1().get0(); + auto rd1 = cache.make_flat_reader(gen.schema()); + rd1.fill_buffer().get(); // Merge m2 into cache auto mt = make_lw_shared(gen.schema()); mt->apply(m2); cache.update([&] { underlying.apply(m2); }, *mt).get(); - auto rd2 = cache.make_reader(gen.schema()); - auto sm2 = rd2().get0(); + auto rd2 = cache.make_flat_reader(gen.schema()); + rd2.fill_buffer().get(); - assert_that(std::move(sm1)).has_mutation().is_equal_to(m1); - assert_that(std::move(sm2)).has_mutation().is_equal_to(m1 + m2); + assert_that(std::move(rd1)).next_mutation().is_equal_to(m1); + assert_that(std::move(rd2)).next_mutation().is_equal_to(m1 + m2); }); }