

def _add_timeout(self, _, exc=None, **kw):
    if (not self.closed):
        self._cancel_timeout(_, exc=exc)
        if (self._timeout and (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/original