[−][src]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. Note that you likely want to avoid
usage of collect
or such on the returned stream as it will exhaust
available memory as it tries to just fill up all RAM.
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());