mirror of
https://github.com/OMGeeky/tarpc.git
synced 2025-12-29 07:40:14 +01:00
Latency benchmark: drive the client with the same reactor as server (so it's entirely single-threaded) (#116)
This commit is contained in:
@@ -45,7 +45,8 @@ fn latency(bencher: &mut Bencher) {
|
||||
server::Options::default())
|
||||
.unwrap();
|
||||
reactor.handle().spawn(server);
|
||||
let client = reactor.run(FutureClient::connect(addr, client::Options::default())).unwrap();
|
||||
let client = FutureClient::connect(addr, client::Options::default().handle(reactor.handle()));
|
||||
let client = reactor.run(client).unwrap();
|
||||
|
||||
bencher.iter(|| reactor.run(client.ack()).unwrap());
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user