base.py 文件源码

def create_dest_stream(self, dest_addr_info):
        dest_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM, 0)
        dest_stream = MicroProxyIOStream(dest_socket)
        yield gen.with_timeout(
            timedelta(seconds=5), dest_stream.connect(dest_addr_info))
        raise gen.Return(dest_stream)