Skip to content

Commit 31701d7

Browse files
author
Rafał Hibner
committed
Merge branch 'PushGeneratorWithBackpressure' into combined2
2 parents e250fbe + 04b9905 commit 31701d7

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

cpp/src/arrow/util/async_generator.h

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -925,7 +925,7 @@ class PushGenerator {
925925

926926
struct StateWithBackpressure : public State {
927927
explicit StateWithBackpressure(acero::BackpressureHandler handler)
928-
: handler_(handler) {}
928+
: handler_(std::move(handler)) {}
929929

930930
struct DoHandle {
931931
explicit DoHandle(StateWithBackpressure& state)
@@ -944,13 +944,13 @@ class PushGenerator {
944944

945945
bool Push(Result<T> result) override {
946946
auto lock = State::mutex.Lock();
947-
DoHandle(*this);
948-
return PushUnlocked(std::move(result), std::move(lock));
947+
DoHandle do_handle(*this);
948+
return State::PushUnlocked(std::move(result), std::move(lock));
949949
}
950950

951951
Future<T> Pop() override {
952952
auto lock = State::mutex.Lock();
953-
DoHandle(*this);
953+
DoHandle do_handle(*this);
954954
return State::PopUnlocked();
955955
}
956956

0 commit comments

Comments
 (0)