Method receive_message

pymongo/asynchronous/pool.py:450–459

Receive a raw BSON message or raise ConnectionFailure. If any exception is raised, the socket is closed.

(self, request_id: Optional[int])

            await self._raise_connection_failure(error)

    async def receive_message(self, request_id: Optional[int]) -> Union[_OpReply, _OpMsg]:
        """Receive a raw BSON message or raise ConnectionFailure.

        If any exception is raised, the socket is closed.
        """
        try:
            return await async_receive_message(self, request_id, self.max_message_size)
        # Catch KeyboardInterrupt, CancelledError, etc. and cleanup.
        except BaseException as error:
            await self._raise_connection_failure(error)

    def _raise_if_not_writable(self, unacknowledged: bool) -> None:
        """Raise NotPrimaryError on unacknowledged write if this socket is not