@@ -20,11 +20,8 @@ async fn try_main(args: Vec<String>) -> Result<(), Box<dyn std::error::Error>> {
2020 . to_socket_addrs ( ) ?
2121 . next ( )
2222 . expect ( "could not parse address" ) ;
23- let addr2 = addr. clone ( ) ;
24- let ( foo_client, set_target) = auto_reconnect ( move || {
25- let addr = addr;
26- Ok ( new_future_client ( connect ( addr, false ) ) )
27- } ) ?;
23+ let ( foo_client, set_target) =
24+ auto_reconnect ( move || Ok ( new_future_client ( connect ( addr, false ) ) ) ) ?;
2825
2926 let mut request = foo_client. identity_request ( ) ;
3027 request. get ( ) . set_x ( 123 ) ;
@@ -55,7 +52,7 @@ async fn try_main(args: Vec<String>) -> Result<(), Box<dyn std::error::Error>> {
5552 // Tell server to crash again
5653 foo_client. crash_request ( ) . send ( ) . promise . await ?;
5754 // Use set_target to set new connection
58- set_target. set_target ( new_future_client ( connect ( addr2 , true ) ) ) ;
55+ set_target. set_target ( new_future_client ( connect ( addr , true ) ) ) ;
5956
6057 // Send request that uses the new target
6158 let mut request = foo_client. identity_request ( ) ;
@@ -81,6 +78,6 @@ async fn connect<A: ToSocketAddrs>(addr: A, manual: bool) -> capnp::Result<foo::
8178 let mut rpc_system = RpcSystem :: new ( network, None ) ;
8279 let calculator: foo:: Client = rpc_system. bootstrap ( rpc_twoparty_capnp:: Side :: Server ) ;
8380 tokio:: task:: spawn_local ( rpc_system) ;
84- eprintln ! ( "Connected (manual={})" , manual ) ;
81+ eprintln ! ( "Connected (manual={manual })" ) ;
8582 Ok ( calculator)
8683}
0 commit comments