

def _recver(self):
    while True:
        event = self._channel.recv()
        if (self._compat_v2 is None):
            self._compat_v2 = (event.header.get('v', 0) < 3)
        if (event.name == '_zpc_hb'):
            self._remote_last_hb = time.time()
            self._start_heartbeat()
            if event._compat_v2:
                event.name = '_zpc_more'
                self._input_queue.put(event)
        else:
            self._input_queue.put(event)

dataset/ETHPy150Open 0rpc/zerorpc-python/zerorpc/heartbeat.py HeartBeatOnChannel._recver/VarMisuse@84/109 `self`->`event`