From 108e1a2c1a66a6f0123704e42624b51e9536476f Mon Sep 17 00:00:00 2001 From: Alex Crichton Date: Tue, 5 Dec 2017 09:02:07 -0800 Subject: 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' --- benches/latency.rs | 4 ++-- benches/tcp.rs | 10 +++++----- 2 files changed, 7 insertions(+), 7 deletions(-) (limited to 'benches') 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(); -- cgit v1.2.3