Method ReadNext

cpp/src/arrow/c/bridge.cc:2396–2409

  std::shared_ptr<Schema> schema() const override { return schema_; }

  Status ReadNext(std::shared_ptr<RecordBatch>* batch) override {
    ARROW_RETURN_NOT_OK(this->CheckNotReleased());

    ArrayType c_array;
    ARROW_RETURN_NOT_OK(this->ReadNextArrayInternal(&c_array));

    if (ArrayTraits::IsReleasedFunc(&c_array)) {
      // End of stream
      batch->reset();
      return Status::OK();
    } else {
      return this->ImportRecordBatchInternal(&c_array, schema_).Value(batch);
    }
  }

  Status Close() override {
    this->ReleaseStream();