Function pycbc_scan_iterator__iternext__

src/result.cxx:327–349

}

static PyObject*
pycbc_scan_iterator__iternext__(PyObject* self)
{
  pycbc_scan_iterator* scan_iter = reinterpret_cast<pycbc_scan_iterator*>(self);

  tl::expected<couchbase::core::range_scan_item, std::error_code> result;
  {
    Py_BEGIN_ALLOW_THREADS result = scan_iter->scan_result->next();
    Py_END_ALLOW_THREADS
  }

  if (!result.has_value()) {
    return build_exception(
      result.error(), __FILE__, __LINE__, "Error retrieving next scan result item.");
  }
  PyObject* pyObj = create_pycbc_result();
  if (pyObj == nullptr) {
    return nullptr;
  }
  pycbc_result* res = reinterpret_cast<pycbc_result*>(pyObj);
  add_field<couchbase::core::range_scan_item>(res->raw_result, "scan_item", result.value());
  return reinterpret_cast<PyObject*>(res);
}

static PyObject*
pycbc_scan_iterator__cancel__(pycbc_scan_iterator* self, PyObject* args)