def __enter__(self):
        self._timer_id = self._connection.add_timeout(
            self._duration,
            self._callback_result.signal_once)
        return self
Register a timer
dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/_IoloopTimerContext.__enter__