OMGeeky/tarpc
1
0
Fork 0
mirror of https://github.com/OMGeeky/tarpc.git synced 2026-01-06 19:45:25 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix test client breakage by 9100ea46f997f24d4bc8c1764d0fe3ff8226ad2a

Browse Source
This commit is contained in:
Artem Vorotnikov
2019-04-03 20:37:36 +03:00
parent 4569d26d81
commit 8665655592
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
bincode-transport/tests/cancel.rs
View File

@@ -11,7 +11,7 @@
use futures::{
compat::{Executor01CompatExt, Future01CompatExt},
prelude::*,
stream,
stream::FuturesUnordered,
};
use log::{info, trace};
use rand::distributions::{Distribution, Normal};
@@ -126,7 +126,10 @@ async fn run() -> io::Result<()> {
let response = client.call(ctx, "ping".into());
requests.push(response.map(move |r| (trace_id, r)));
}
let (fastest_response, _) = await!(stream::futures_unordered(requests).into_future());
let (fastest_response, _) = await!(requests
.into_iter()
.collect::<FuturesUnordered<_>>()
.into_future());
let (trace_id, resp) = fastest_response.unwrap();
info!("[{}] fastest_response = {:?}", trace_id, resp);