Method read_response

redis/asyncio/connection.py:742–825

Read the response from a previously sent command. ``timeout`` semantics: - ``None`` (default): fall back to ``self.socket_timeout``. - ``math.inf``: block indefinitely with no timeout. Used by PubSub blocking reads (``listen()`` / ``get_message(timeout=None)`` /

(
        self,
        disable_decoding: bool = False,
        timeout: Optional[float] = None,
        *,
        disconnect_on_error: bool = True,
        push_request: Optional[bool] = False,
    )

            raise ConnectionError(f"Error while reading from {host_error}: {e.args}")

    async def read_response(
        self,
        disable_decoding: bool = False,
        timeout: Optional[float] = None,
        *,
        disconnect_on_error: bool = True,
        push_request: Optional[bool] = False,
    ):
        """Read the response from a previously sent command.

        ``timeout`` semantics:
        - ``None`` (default): fall back to ``self.socket_timeout``.
        - ``math.inf``: block indefinitely with no timeout. Used by PubSub
          blocking reads (``listen()`` / ``get_message(timeout=None)`` /
          ``parse_response(block=True)``) where the configured
          ``socket_timeout`` must not abort the read.
        - ``float``: apply that timeout in seconds for this single read.

        TODO(next-major): replace the ``math.inf`` opt-in with a SENTINEL
        default for ``timeout``. After that change, ``timeout=None`` will
        mean "no timeout, block until a response arrives" (matching the
        long-standing PubSub docstring contract) and the SENTINEL default
        will be the value that falls back to ``self.socket_timeout``.
        That swap is a breaking change, so it must wait for a major
        release. Until then, callers that need an indefinitely blocking
        read pass ``math.inf`` explicitly.
        """
        # TODO(next-major): drop the math.inf branch. Use SENTINEL as the
        # default for ``timeout`` and treat ``timeout is None`` as the
        # "no timeout" signal (matching the PubSub docstring contract).
        # Match only positive infinity here. ``-math.inf`` is not a valid
        # "block forever" signal and historically behaved as an already-
        # expired timeout; preserve that.
        if timeout == math.inf:
            read_timeout = None
        else:
            read_timeout = timeout if timeout is not None else self.socket_timeout
        host_error = self._host_error()
        try:
            if read_timeout is not None and self.protocol in ["3", 3]:
                async with async_timeout(read_timeout):
                    response = await self._parser.read_response(
                        disable_decoding=disable_decoding, push_request=push_request
                    )
            elif read_timeout is not None:
                async with async_timeout(read_timeout):
                    response = await self._parser.read_response(
                        disable_decoding=disable_decoding
                    )
            elif self.protocol in ["3", 3]:
                response = await self._parser.read_response(
                    disable_decoding=disable_decoding, push_request=push_request
                )
            else:
                response = await self._parser.read_response(
                    disable_decoding=disable_decoding
                )
        except asyncio.TimeoutError: