Skip to content

Commit 588f5b4

Browse files
committed
---
yaml --- r: 72113 b: refs/heads/dist-snap c: 0f85cf1 h: refs/heads/master i: 72111: 20d9f07 v: v3
1 parent b294cb3 commit 588f5b4

File tree

3 files changed

+90
-1
lines changed

3 files changed

+90
-1
lines changed

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105
77
refs/heads/ndm: f3868061cd7988080c30d6d5bf352a5a5fe2460b
88
refs/heads/try2: 147ecfdd8221e4a4d4e090486829a06da1e0ca3c
99
refs/heads/incoming: b50030718cf28f2a5a81857a26b57442734fe854
10-
refs/heads/dist-snap: d3a58f37979496efdf15bf016ebccc17b007a6cc
10+
refs/heads/dist-snap: 0f85cf180a430c066d5b86db0998d124f8dff03b
1111
refs/tags/release-0.2: c870d2dffb391e14efb05aa27898f1f6333a9596
1212
refs/tags/release-0.3: b5f0d0f648d9a6153664837026ba1be43d3e2503
1313
refs/heads/try3: 9387340aab40a73e8424c48fd42f0c521a4875c0

branches/dist-snap/src/libcore/iterator.rs

Lines changed: 61 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,8 @@ pub trait IteratorUtil<A> {
2424
fn filter<'r>(self, predicate: &'r fn(&A) -> bool) -> FilterIterator<'r, A, Self>;
2525
fn dropwhile<'r>(self, predicate: &'r fn(&A) -> bool) -> DropWhileIterator<'r, A, Self>;
2626
fn takewhile<'r>(self, predicate: &'r fn(&A) -> bool) -> TakeWhileIterator<'r, A, Self>;
27+
fn skip(self, n: uint) -> SkipIterator<Self>;
28+
fn take(self, n: uint) -> TakeIterator<Self>;
2729
fn enumerate(self) -> EnumerateIterator<Self>;
2830
fn advance(&mut self, f: &fn(A) -> bool);
2931
}
@@ -60,6 +62,16 @@ impl<A, T: Iterator<A>> IteratorUtil<A> for T {
6062
TakeWhileIterator{iter: self, flag: false, predicate: predicate}
6163
}
6264

65+
#[inline(always)]
66+
fn skip(self, n: uint) -> SkipIterator<T> {
67+
SkipIterator{iter: self, n: n}
68+
}
69+
70+
#[inline(always)]
71+
fn take(self, n: uint) -> TakeIterator<T> {
72+
TakeIterator{iter: self, n: n}
73+
}
74+
6375
/// A shim implementing the `for` loop iteration protocol for iterator objects
6476
#[inline]
6577
fn advance(&mut self, f: &fn(A) -> bool) {
@@ -199,3 +211,52 @@ impl<'self, A, T: Iterator<A>> Iterator<A> for TakeWhileIterator<'self, A, T> {
199211
}
200212
}
201213
}
214+
215+
pub struct SkipIterator<T> {
216+
priv iter: T,
217+
priv n: uint
218+
}
219+
220+
impl<A, T: Iterator<A>> Iterator<A> for SkipIterator<T> {
221+
#[inline]
222+
fn next(&mut self) -> Option<A> {
223+
let mut next = self.iter.next();
224+
if self.n == 0 {
225+
next
226+
} else {
227+
let n = self.n;
228+
for n.times {
229+
match next {
230+
Some(_) => {
231+
next = self.iter.next();
232+
loop
233+
}
234+
None => {
235+
self.n = 0;
236+
return None
237+
}
238+
}
239+
}
240+
self.n = 0;
241+
next
242+
}
243+
}
244+
}
245+
246+
pub struct TakeIterator<T> {
247+
priv iter: T,
248+
priv n: uint
249+
}
250+
251+
impl<A, T: Iterator<A>> Iterator<A> for TakeIterator<T> {
252+
#[inline]
253+
fn next(&mut self) -> Option<A> {
254+
let next = self.iter.next();
255+
if self.n != 0 {
256+
self.n -= 1;
257+
next
258+
} else {
259+
None
260+
}
261+
}
262+
}

branches/dist-snap/src/libcore/vec.rs

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4512,4 +4512,32 @@ mod tests {
45124512
}
45134513
assert_eq!(i, ys.len());
45144514
}
4515+
4516+
#[test]
4517+
fn test_iterator_skip() {
4518+
use iterator::*;
4519+
let xs = [0u, 1, 2, 3, 5, 13, 15, 16, 17, 19, 20, 30];
4520+
let ys = [13, 15, 16, 17, 19, 20, 30];
4521+
let mut it = xs.iter().skip(5);
4522+
let mut i = 0;
4523+
for it.advance |&x: &uint| {
4524+
assert_eq!(x, ys[i]);
4525+
i += 1;
4526+
}
4527+
assert_eq!(i, ys.len());
4528+
}
4529+
4530+
#[test]
4531+
fn test_iterator_take() {
4532+
use iterator::*;
4533+
let xs = [0u, 1, 2, 3, 5, 13, 15, 16, 17, 19];
4534+
let ys = [0u, 1, 2, 3, 5];
4535+
let mut it = xs.iter().take(5);
4536+
let mut i = 0;
4537+
for it.advance |&x: &uint| {
4538+
assert_eq!(x, ys[i]);
4539+
i += 1;
4540+
}
4541+
assert_eq!(i, ys.len());
4542+
}
45154543
}

0 commit comments

Comments
 (0)