From 7306f53be165a4df1aa1c7bbf4e3984f4654f232 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Botond=20D=C3=A9nes?= Date: Thu, 9 Dec 2021 10:59:51 +0200 Subject: [PATCH] flat_mutation_reader: make_forwardable(): fix indentation --- flat_mutation_reader.cc | 32 ++++++++++++++++---------------- 1 file changed, 16 insertions(+), 16 deletions(-) diff --git a/flat_mutation_reader.cc b/flat_mutation_reader.cc index 2a679747be..ffb5fe99b0 100644 --- a/flat_mutation_reader.cc +++ b/flat_mutation_reader.cc @@ -278,9 +278,9 @@ flat_mutation_reader make_forwardable(flat_mutation_reader m) { co_return; } _next = co_await _underlying(); - if (!_next) { - _end_of_stream = true; - } + if (!_next) { + _end_of_stream = true; + } } public: reader(flat_mutation_reader r) : impl(r.schema(), r.permit()), _underlying(std::move(r)), _current({ @@ -290,19 +290,19 @@ flat_mutation_reader make_forwardable(flat_mutation_reader m) { virtual future<> fill_buffer() override { while (!is_buffer_full()) { co_await ensure_next(); - if (is_end_of_stream()) { - break; - } - position_in_partition::less_compare cmp(*_schema); - if (!cmp(_next->position(), _current.end())) { - _end_of_stream = true; - // keep _next, it may be relevant for next range - break; - } - if (_next->relevant_for_range(*_schema, _current.start())) { - push_mutation_fragment(std::move(*_next)); - } - _next = {}; + if (is_end_of_stream()) { + break; + } + position_in_partition::less_compare cmp(*_schema); + if (!cmp(_next->position(), _current.end())) { + _end_of_stream = true; + // keep _next, it may be relevant for next range + break; + } + if (_next->relevant_for_range(*_schema, _current.start())) { + push_mutation_fragment(std::move(*_next)); + } + _next = {}; } } virtual future<> fast_forward_to(position_range pr) override {