Method read_response

redis/_parsers/resp2.py:13–27

(
        self, disable_decoding=False, timeout: Union[float, object] = SENTINEL
    )

    """RESP2 protocol implementation"""

    def read_response(
        self, disable_decoding=False, timeout: Union[float, object] = SENTINEL
    ):
        pos = self._buffer.get_pos() if self._buffer else None
        try:
            result = self._read_response(
                disable_decoding=disable_decoding, timeout=timeout
            )
        except BaseException:
            if self._buffer:
                self._buffer.rewind(pos)
            raise
        else:
            self._buffer.purge()
            return result

    def _read_response(
        self, disable_decoding=False, timeout: Union[float, object] = SENTINEL