Function stream_next

couchbase/logic/streaming.py:78–105

**INTERNAL** Drive a single synchronous streaming iteration for ``req`` and apply uniform teardown/error handling. Shared by the blocking (``couchbase``) and Twisted (``txcouchbase``) row iterators.

(req)

def stream_next(req):
    """
    **INTERNAL**

    Drive a single synchronous streaming iteration for ``req`` and apply uniform teardown/error
    handling.  Shared by the blocking (``couchbase``) and Twisted (``txcouchbase``) row iterators.
    """
    try:
        row = req._get_next_row()
        # See stream_anext for why the span is ended here (idempotent, ends on the first row).
        req._process_core_span()
        return row
    except StopIteration:
        req._done_streaming = True
        req._process_core_span()
        req._get_metadata()
        raise
    except CouchbaseException as ex:
        req._process_core_span(exc_val=ex)
        raise
    except Exception as ex:
        excptn = _internal_exception(str(ex))
        req._process_core_span(exc_val=excptn)
        raise excptn
    except BaseException as ex:
        # KeyboardInterrupt / SystemExit -- see module note above.
        req._process_core_span(exc_val=ex)
        raise