Skip to content

Commit 3023951

Browse files
committed
---
yaml --- r: 57012 b: refs/heads/try c: 0f85cf1 h: refs/heads/master v: v3
1 parent 78c94a0 commit 3023951

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
@@ -2,7 +2,7 @@
22
refs/heads/master: c081ffbd1e845687202a975ea2e698b623e5722f
33
refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
44
refs/heads/snap-stage3: 79a2b2eafc3c766cecec8a5f76317693bae9ed17
5-
refs/heads/try: d3a58f37979496efdf15bf016ebccc17b007a6cc
5+
refs/heads/try: 0f85cf180a430c066d5b86db0998d124f8dff03b
66
refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105
77
refs/heads/ndm: f3868061cd7988080c30d6d5bf352a5a5fe2460b
88
refs/heads/try2: 147ecfdd8221e4a4d4e090486829a06da1e0ca3c

branches/try/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/try/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)