Function futures::stream::repeat

pub fn repeat<T, E>(item: T) -> Repeat<T, E> where
    T: Clone, 

Create a stream which produces the same item repeatedly.

Stream never produces an error or EOF.

use futures::*;

let mut stream = stream::repeat::<_, bool>(10);
assert_eq!(Ok(Async::Ready(Some(10))), stream.poll());
assert_eq!(Ok(Async::Ready(Some(10))), stream.poll());
assert_eq!(Ok(Async::Ready(Some(10))), stream.poll());