diff options
author | Alex Crichton <alex@alexcrichton.com> | 2017-12-05 09:02:07 -0800 |
---|---|---|
committer | Alex Crichton <alex@alexcrichton.com> | 2017-12-05 09:02:07 -0800 |
commit | 108e1a2c1a66a6f0123704e42624b51e9536476f (patch) | |
tree | 627489b7aa04cd2da9cdfdf53172e235fc7a6827 /benches | |
parent | 46062794aaedf1d2f8385124fa5b7061317a2527 (diff) |
Blanket rename `Core` to `Reactor`
This commit uses a script to rename `Core` to `Reactor` all at once, notably:
find . -name '*.rs' | xargs sed -i 's/\bCore\b/Reactor/g'
Diffstat (limited to 'benches')
-rw-r--r-- | benches/latency.rs | 4 | ||||
-rw-r--r-- | benches/tcp.rs | 10 |
2 files changed, 7 insertions, 7 deletions
diff --git a/benches/latency.rs b/benches/latency.rs index fd34c0e6..246d033b 100644 --- a/benches/latency.rs +++ b/benches/latency.rs @@ -16,7 +16,7 @@ use futures::sync::mpsc; use futures::{Future, Poll, Sink, Stream}; use test::Bencher; use tokio::net::UdpSocket; -use tokio::reactor::Core; +use tokio::reactor::Reactor; /// UDP echo server struct EchoServer { @@ -59,7 +59,7 @@ fn udp_echo_latency(b: &mut Bencher) { let (tx, rx) = oneshot::channel(); let child = thread::spawn(move || { - let mut l = Core::new().unwrap(); + let mut l = Reactor::new().unwrap(); let handle = l.handle(); let socket = tokio::net::UdpSocket::bind(&any_addr, &handle).unwrap(); diff --git a/benches/tcp.rs b/benches/tcp.rs index 245ed881..82dc6835 100644 --- a/benches/tcp.rs +++ b/benches/tcp.rs @@ -10,7 +10,7 @@ pub extern crate test; mod prelude { pub use futures::*; - pub use tokio::reactor::Core; + pub use tokio::reactor::Reactor; pub use tokio::net::{TcpListener, TcpStream}; pub use tokio_io::io::read_to_end; @@ -29,7 +29,7 @@ mod connect_churn { #[bench] fn one_thread(b: &mut Bencher) { let addr = "127.0.0.1:0".parse().unwrap(); - let mut core = Core::new().unwrap(); + let mut core = Reactor::new().unwrap(); let handle = core.handle(); let listener = TcpListener::bind(&addr, &handle).unwrap(); let addr = listener.local_addr().unwrap(); @@ -63,7 +63,7 @@ mod connect_churn { // Spawn reactor thread thread::spawn(move || { // Create the core - let mut core = Core::new().unwrap(); + let mut core = Reactor::new().unwrap(); // Reactor handles let handle = core.handle(); @@ -209,7 +209,7 @@ mod transfer { fn one_thread(b: &mut Bencher, read_size: usize, write_size: usize) { let addr = "127.0.0.1:0".parse().unwrap(); - let mut core = Core::new().unwrap(); + let mut core = Reactor::new().unwrap(); let handle = core.handle(); let listener = TcpListener::bind(&addr, &handle).unwrap(); let addr = listener.local_addr().unwrap(); @@ -255,7 +255,7 @@ mod transfer { // Spawn reactor thread thread::spawn(move || { // Create the core - let mut core = Core::new().unwrap(); + let mut core = Reactor::new().unwrap(); // Reactor handles let handle = core.handle(); |