Method WaitForNextReleasedBatch

cpp/src/arrow/acero/test_nodes.cc:221–234

  }

  Future<> WaitForNextReleasedBatch() {
    std::lock_guard lg(mutex_);
    if (current_waiter_.is_valid()) {
      return current_waiter_;
    }
    Future<> fut;
    if (num_allowed_batches_ < 0 || num_released_batches_ < num_allowed_batches_) {
      num_released_batches_++;
      return Future<>::MakeFinished();
    }

    current_waiter_ = Future<>::Make();
    return current_waiter_;
  }

 private:
  void NotifyAll() {