diff options
Diffstat (limited to 'src/libstd/rt')
| -rw-r--r-- | src/libstd/rt/borrowck.rs | 2 | ||||
| -rw-r--r-- | src/libstd/rt/mod.rs | 6 | ||||
| -rw-r--r-- | src/libstd/rt/select.rs | 10 | ||||
| -rw-r--r-- | src/libstd/rt/test.rs | 8 | ||||
| -rw-r--r-- | src/libstd/rt/uv/net.rs | 9 |
5 files changed, 18 insertions, 17 deletions
diff --git a/src/libstd/rt/borrowck.rs b/src/libstd/rt/borrowck.rs index 2d489e4dbc3..bb66a901234 100644 --- a/src/libstd/rt/borrowck.rs +++ b/src/libstd/rt/borrowck.rs @@ -83,7 +83,7 @@ unsafe fn fail_borrowed(box: *mut raw::Box<()>, file: *c_char, line: size_t) { Some(borrow_list) => { // recording borrows let mut msg = ~"borrowed"; let mut sep = " at "; - for borrow_list.rev_iter().advance |entry| { + foreach entry in borrow_list.rev_iter() { if entry.box == box { msg.push_str(sep); let filename = str::raw::from_c_str(entry.file); diff --git a/src/libstd/rt/mod.rs b/src/libstd/rt/mod.rs index dc8669b9264..44418001f14 100644 --- a/src/libstd/rt/mod.rs +++ b/src/libstd/rt/mod.rs @@ -64,7 +64,7 @@ use cell::Cell; use clone::Clone; use container::Container; use iter::Times; -use iterator::IteratorUtil; +use iterator::{Iterator, IteratorUtil}; use option::{Some, None}; use ptr::RawPtr; use rt::sched::{Scheduler, Shutdown}; @@ -291,7 +291,7 @@ fn run_(main: ~fn(), use_main_sched: bool) -> int { let on_exit: ~fn(bool) = |exit_success| { let mut handles = handles.take(); - for handles.mut_iter().advance |handle| { + foreach handle in handles.mut_iter() { handle.send(Shutdown); } @@ -346,7 +346,7 @@ fn run_(main: ~fn(), use_main_sched: bool) -> int { } // Wait for schedulers - for threads.consume_iter().advance() |thread| { + foreach thread in threads.consume_iter() { thread.join(); } diff --git a/src/libstd/rt/select.rs b/src/libstd/rt/select.rs index bc9e265c8d9..6296186aa49 100644 --- a/src/libstd/rt/select.rs +++ b/src/libstd/rt/select.rs @@ -37,7 +37,7 @@ pub fn select<A: Select>(ports: &mut [A]) -> uint { fail!("can't select on an empty list"); } - for ports.mut_iter().enumerate().advance |(index, port)| { + foreach (index, port) in ports.mut_iter().enumerate() { if port.optimistic_check() { return index; } @@ -66,7 +66,7 @@ pub fn select<A: Select>(ports: &mut [A]) -> uint { // Task resumes. Now unblock ourselves from all the ports we blocked on. // If the success index wasn't reset, 'take' will just take all of them. // Iterate in reverse so the 'earliest' index that's ready gets returned. - for ports.mut_slice(0, ready_index).mut_rev_iter().enumerate().advance |(index, port)| { + foreach (index, port) in ports.mut_slice(0, ready_index).mut_rev_iter().enumerate() { if port.unblock_from() { ready_index = index; } @@ -127,7 +127,7 @@ mod test { let (ports, chans) = unzip(from_fn(num_ports, |_| oneshot::<()>())); let mut dead_chans = ~[]; let mut ports = ports; - for chans.consume_iter().enumerate().advance |(i, chan)| { + foreach (i, chan) in chans.consume_iter().enumerate() { if send_on_chans.contains(&i) { chan.send(()); } else { @@ -144,7 +144,7 @@ mod test { let (ports, chans) = unzip(from_fn(num_ports, |_| stream::<()>())); let mut dead_chans = ~[]; let mut ports = ports; - for chans.consume_iter().enumerate().advance |(i, chan)| { + foreach (i, chan) in chans.consume_iter().enumerate() { if send_on_chans.contains(&i) { chan.send(()); } else { @@ -191,7 +191,7 @@ mod test { let mut ports = ports; let mut port = Some(port); let order = [5u,0,4,3,2,6,9,8,7,1]; - for order.iter().advance |&index| { + foreach &index in order.iter() { // put the port in the vector at any index util::swap(port.get_mut_ref(), &mut ports[index]); assert!(select(ports) == index); diff --git a/src/libstd/rt/test.rs b/src/libstd/rt/test.rs index 260903cbcbf..ec1094ed4f2 100644 --- a/src/libstd/rt/test.rs +++ b/src/libstd/rt/test.rs @@ -14,7 +14,7 @@ use option::{Some, None}; use cell::Cell; use clone::Clone; use container::Container; -use iterator::IteratorUtil; +use iterator::Iterator; use vec::{OwnedVector, MutableVector}; use super::io::net::ip::{IpAddr, Ipv4, Ipv6}; use rt::sched::Scheduler; @@ -100,7 +100,7 @@ pub fn run_in_mt_newsched_task(f: ~fn()) { let on_exit: ~fn(bool) = |exit_status| { let mut handles = handles.take(); // Tell schedulers to exit - for handles.mut_iter().advance |handle| { + foreach handle in handles.mut_iter() { handle.send(Shutdown); } @@ -125,7 +125,7 @@ pub fn run_in_mt_newsched_task(f: ~fn()) { } // Wait for schedulers - for threads.consume_iter().advance() |thread| { + foreach thread in threads.consume_iter() { thread.join(); } } @@ -380,7 +380,7 @@ fn base_port() -> uint { let mut final_base = base; - for bases.iter().advance |&(dir, base)| { + foreach &(dir, base) in bases.iter() { if path.contains(dir) { final_base = base; break; diff --git a/src/libstd/rt/uv/net.rs b/src/libstd/rt/uv/net.rs index 8ea4a197269..773adb3848a 100644 --- a/src/libstd/rt/uv/net.rs +++ b/src/libstd/rt/uv/net.rs @@ -606,6 +606,7 @@ mod test { use rt::test::*; use rt::uv::{Loop, AllocCallback}; use rt::uv::{vec_from_uv_buf, vec_to_uv_buf, slice_to_uv_buf}; + use prelude::*; #[test] fn connect_close_ip4() { @@ -700,7 +701,7 @@ mod test { if status.is_none() { rtdebug!("got %d bytes", nread); let buf = buf.unwrap(); - for buf.slice(0, nread as uint).iter().advance() |byte| { + foreach byte in buf.slice(0, nread as uint).iter() { assert!(*byte == count as u8); rtdebug!("%u", *byte as uint); count += 1; @@ -776,7 +777,7 @@ mod test { rtdebug!("got %d bytes", nread); let buf = buf.unwrap(); let r = buf.slice(0, nread as uint); - for r.iter().advance |byte| { + foreach byte in r.iter() { assert!(*byte == count as u8); rtdebug!("%u", *byte as uint); count += 1; @@ -847,7 +848,7 @@ mod test { rtdebug!("got %d bytes", nread); let buf = buf.unwrap(); - for buf.slice(0, nread as uint).iter().advance() |&byte| { + foreach &byte in buf.slice(0, nread as uint).iter() { assert!(byte == count as u8); rtdebug!("%u", byte as uint); count += 1; @@ -907,7 +908,7 @@ mod test { rtdebug!("got %d bytes", nread); let buf = buf.unwrap(); - for buf.slice(0, nread as uint).iter().advance() |&byte| { + foreach &byte in buf.slice(0, nread as uint).iter() { assert!(byte == count as u8); rtdebug!("%u", byte as uint); count += 1; |
