code: def _resume(self):
          
          try:
              self._cursor.close()
          except PyMongoError:
              pass
          self._cursor = self._create_cursor()
docs: Reestablish this change stream after a resumable error.