We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 518c6f6 commit 49473dfCopy full SHA for 49473df
cpp/src/arrow/util/async_generator.h
@@ -925,7 +925,7 @@ class PushGenerator {
925
926
struct StateWithBackpressure : public State {
927
explicit StateWithBackpressure(acero::BackpressureHandler handler)
928
- : handler_(handler) {}
+ : handler_(std::move(handler)) {}
929
930
struct DoHandle {
931
explicit DoHandle(StateWithBackpressure& state)
@@ -945,7 +945,7 @@ class PushGenerator {
945
bool Push(Result<T> result) override {
946
auto lock = State::mutex.Lock();
947
DoHandle(*this);
948
- return PushUnlocked(std::move(result), std::move(lock));
+ return State::PushUnlocked(std::move(result), std::move(lock));
949
}
950
951
Future<T> Pop() override {
0 commit comments