OMGeeky/tarpc
1
0
Fork 0
mirror of https://github.com/OMGeeky/tarpc.git synced 2026-01-18 17:30:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

Complete ClientFuture on error.

Browse Source
This commit is contained in:
Tim Kuehn
2016-09-30 15:36:55 -04:00
parent b880d65f44
commit b661ff0175
1 changed files with 16 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/client.rs
View File

@@ -115,16 +115,23 @@ pub mod future {
REMOTE.spawn(move |handle| {
let handle2 = handle.clone();
TcpStream::connect(&addr, handle)
.and_then(move |tcp| {
let tcp = RefCell::new(Some(tcp));
let c =
multiplex::connect(move || {
Ok(Framed::new(tcp.borrow_mut().take().unwrap()))
},
&handle2);
Ok(Client { inner: c })
.then(move |tcp| {
match tcp {
Ok(tcp) => {
let tcp = RefCell::new(Some(tcp));
let c =
multiplex::connect(move || {
Ok(Framed::new(tcp.borrow_mut().take().unwrap()))
},
&handle2);
tx.complete(Ok(Client { inner: c }));
}
Err(e) => {
tx.complete(Err(e));
}
}
Ok(())
})
.then(|client| Ok(tx.complete(client)))
});
ClientFuture { inner: rx }
}