(self)
| 47 | return self |
| 48 | |
| 49 | def __next__(self): |
| 50 | try: |
| 51 | return self._get_next_row() |
| 52 | # We can stop iterator when we receive RangeScanCompletedException |
| 53 | except RangeScanCompletedException: |
| 54 | self._done_streaming = True |
| 55 | raise StopIteration |
| 56 | except StopIteration: |
| 57 | self._done_streaming = True |
| 58 | raise |
| 59 | except CouchbaseException as ex: |
| 60 | raise ex |
| 61 | except Exception as ex: |
| 62 | exc_cls = PYCBC_ERROR_MAP.get(ExceptionMap.InternalSDKException.value, CouchbaseException) |
| 63 | excptn = exc_cls(str(ex)) |
| 64 | raise excptn |
nothing calls this directly
no test coverage detected