

def recv(self, timeout=None):
    if self._lost_remote:
        raise self._lost_remote_exception()
    try:
        return self._input_queue.get(timeout=timeout)
    except gevent.queue.Empty:
        raise TimeoutExpired(timeout)

dataset/ETHPy150Open 0rpc/zerorpc-python/zerorpc/heartbeat.py HeartBeatOnChannel.recv/original