test(benches): uses current_thread runtime in server benchmarks
This commit is contained in:
@@ -42,7 +42,9 @@ macro_rules! bench_server {
|
|||||||
.map_err(|e| panic!("server error: {}", e))
|
.map_err(|e| panic!("server error: {}", e))
|
||||||
.select(until_rx.then(|_| Ok(())))
|
.select(until_rx.then(|_| Ok(())))
|
||||||
.then(|_| Ok(()));
|
.then(|_| Ok(()));
|
||||||
tokio::run(fut);
|
let mut rt = tokio::runtime::current_thread::Runtime::new().unwrap();
|
||||||
|
rt.spawn(fut);
|
||||||
|
rt.run().unwrap();
|
||||||
});
|
});
|
||||||
|
|
||||||
addr_rx.recv().unwrap()
|
addr_rx.recv().unwrap()
|
||||||
|
|||||||
Reference in New Issue
Block a user