tikv
/
client-rust
mirror of https://github.com/tikv/client-rust.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' into rpc

This commit is contained in:
Nick Cameron 2019-06-05 07:54:29 +12:00 committed by GitHub
parent d221e026f1 f2687e95a4
commit e88880f568
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/rpc/pd/leader.rs
View File

@ -120,12 +120,11 @@ impl PdReactor {
let mut core = Core::new().unwrap();
let handle = core.handle();
{
let f = rx.take_while(|t| ready(t.is_some())).then(|t| {
let f = rx.take_while(|t| ready(t.is_some())).for_each(|t| {
Self::dispatch(&client, t.unwrap(), &handle);
ready(())
});
core.run(TryFutureExt::compat(f.into_future().unit_error()))
.unwrap();
core.run(TryFutureExt::compat(f.unit_error())).unwrap();
}
}