pub fn connect(addr: &SocketAddr,
                   handle: &Handle)
                   -> Box<Future<Item = Client, Error = io::Error>> {
        let ret = TcpClient::new(RPCProto)
            .connect(addr, handle)
            .map(|client_service| {
                     let s = RPC { inner: client_service };
                     Client { inner: s }
                 });

        Box::new(ret)
    }
/// Establish a connection to a multiplexed protobuf protocol server at the
/// provided `addr`.
Establish a connection to a multiplexed protobuf protocol server at the
provided `addr`.
Establish a connection to a multiplexed protobuf protocol server at the provided ` addr ` .
pub fn connect(addr: &SocketAddr,
                   handle: &Handle)
                   -> Box<Future<Item = Client, Error = io::Error>> {
        let ret = TcpClient::new(RPCProto)
            .connect(addr, handle)
            .map(|client_service| {
                     let s = RPC { inner: client_service };
                     Client { inner: s }
                 });
        Box::new(ret)
    }
pub fn connect ( addr : & SocketAddr , handle : & Handle ) -> Box < Future < Item = Client , Error = io :: Error > > { let ret = TcpClient :: new ( RPCProto ) . connect ( addr , handle ) . map ( | client_service | { let s = RPC { inner : client_service } ; Client { inner : s } } ) ; Box :: new ( ret ) }
Establish a connection to a multiplexed protobuf protocol server at the
provided `addr`.
Establish a connection to a multiplexed protobuf protocol server at the provided ` addr ` .
addr
&SocketAddr
handle
&Handle
addr
&SocketAddr
handle
&Handle