From 751c27f792d91d6a58d7601334eb17ae33295061 Mon Sep 17 00:00:00 2001 From: jeremy Date: Tue, 20 Dec 2022 10:12:50 +0100 Subject: [PATCH] Get ride of attribute has_valid_frames_ --- src/query/v2/plan/operator.cpp | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/src/query/v2/plan/operator.cpp b/src/query/v2/plan/operator.cpp index b6bbf9ce1..f162ec9ea 100644 --- a/src/query/v2/plan/operator.cpp +++ b/src/query/v2/plan/operator.cpp @@ -516,11 +516,11 @@ class DistributedScanAllAndFilterCursor : public Cursor { valid_frames_it_ = valid_frames_consumer_->begin(); MakeRequest(request_router, context); - - has_next_frame_ = current_vertex_it_ != current_batch_.end() && valid_frames_it_ != valid_frames_consumer_->end(); } - inline bool HasNextFrame() const { return has_next_frame_; } + inline bool HasNextFrame() { + return current_vertex_it_ != current_batch_.end() && valid_frames_it_ != valid_frames_consumer_->end(); + } FrameWithValidity GetNextFrame(ExecutionContext &context) { MG_ASSERT(HasNextFrame()); @@ -600,7 +600,6 @@ class DistributedScanAllAndFilterCursor : public Cursor { std::optional valid_frames_consumer_; ValidFramesConsumer::Iterator valid_frames_it_; std::queue frames_buffer_; - bool has_next_frame_; }; ScanAll::ScanAll(const std::shared_ptr &input, Symbol output_symbol, storage::v3::View view)