(service = VoidService, config = {}, remote_service = VoidService, remote_config = {})
return connect(host, port, service = service, config = config)
starts an rpyc server on a new thread, bound to an arbitrary port, 
    and connects to it over a socket.
    
    :param service: the local service to expose (defaults to Void)
    :param config: configuration dict
    :param server_service: the remote service to expose (of the server; defaults to Void)
    :param server_config: remote configuration dict (of the server)
starts an rpyc server on a new thread, bound to an arbitrary port, 
    and connects to it over a socket.
    
    :param service: the local service to expose (defaults to Void)
    :param config: configuration dict
    :param server_service: the remote service to expose (of the server; defaults to Void)
    :param server_config: remote configuration dict (of the server)
starts an rpyc server on a new thread bound to an arbitrary port and connects to it over a socket . : param service : the local service to expose ( defaults to Void ) : param config : configuration dict : param server_service : the remote service to expose ( of the server ; defaults to Void ) : param server_config : remote configuration dict ( of the server )
def connect_thread(service = VoidService, config = {}, remote_service = VoidService, remote_config = {}):
    """starts an rpyc server on a new thread, bound to an arbitrary port, 
    and connects to it over a socket.
    
    :param service: the local service to expose (defaults to Void)
    :param config: configuration dict
    :param server_service: the remote service to expose (of the server; defaults to Void)
    :param server_config: remote configuration dict (of the server)
    """
    listener = socket.socket()
    listener.bind(("localhost", 0))
    listener.listen(1)

    def server(listener = listener):
        client = listener.accept()[0]
        listener.close()
        conn = connect_stream(SocketStream(client), service = remote_service,
            config = remote_config)
        try:
            conn.serve_all()
        except KeyboardInterrupt:
            interrupt_main()

    t = threading.Thread(target = server)
    t.setDaemon(True)
    t.start()
    host, port = listener.getsockname()
    return connect(host, port, service = service, config = config)
def connect_thread ( service = VoidService , config = { } , remote_service = VoidService , remote_config = { } ) : listener = socket . socket ( ) listener . bind ( ( "localhost" , 0 ) ) listener . listen ( 1 ) def server ( listener = listener ) : client = listener . accept ( ) [ 0 ] listener . close ( ) conn = connect_stream ( SocketStream ( client ) , service = remote_service , config = remote_config ) try : conn . serve_all ( ) except KeyboardInterrupt : interrupt_main ( ) t = threading . Thread ( target = server ) t . setDaemon ( True ) t . start ( ) host , port = listener . getsockname ( ) return connect ( host , port , service = service , config = config )