Method _resume

pymongo/synchronous/change_stream.py:261–267

Reestablish this change stream after a resumable error.

(self)

            return self._run_aggregation_cmd(session=s)

    def _resume(self) -> None:
        """Reestablish this change stream after a resumable error."""
        try:
            self._cursor.close()
        except PyMongoError:
            pass
        self._cursor = self._create_cursor()

    def close(self) -> None:
        """Close this ChangeStream."""