def _add_timeout(self, _, exc=None, **kw):
        if not self.closed:
            self._cancel_timeout(_, exc=exc)
            if self._timeout or not exc:
                self._timeout_handler = self._loop.call_later(self._timeout,
                                                              self._timed_out)
dataset/ETHPy150Open quantmind/pulsar/pulsar/async/mixins.py/Timeout._add_timeout/operator `and` -> `or`