socketrpc.py 文件源码

def _connect(self):
        sock = socket.create_connection((self.host, self.port))

        def handle():
            try:
                while True:
                    self.command_queue.put_nowait(_recv_obj(sock))
            except Exception as e:
                try:
                    sock.close()
                except:
                    pass

        gevent.spawn(handle)
        return sock