tokio-bits 0.1.2

A collection of modules useful when developing Tokio based applications.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use futures::{Stream, Async, Poll};

use ops::inc::Incrementable;

/// A stream that produces a range of numbers
pub struct RangeStream<T> {
    next: T,
    end: T,
}

impl<T> RangeStream<T> {
    /// Create a new RangeStream producing values starting at start
    /// and ending at one before end.
    pub fn new(start: T, end: T) -> RangeStream<T> {
        RangeStream {
            next: start,
            end: end,
        }
    }
}

/// The implementation of the Stream trait uses the generic
/// post_inc() to produce the next value.
impl<T: Incrementable + ::std::cmp::PartialOrd> Stream for RangeStream<T> {
    type Item = T;

    type Error = ();

    fn poll(&mut self) -> Poll<Option<Self::Item>, Self::Error> {
        if self.next >= self.end {
            Ok(Async::Ready(None))
        } else {
            let v = self.next;
            self.next.post_inc();
            Ok(Async::Ready(Some(v)))
        }
    }
}