Function futures_util::stream::repeat

source ·
pub fn repeat<T>(item: T) -> Repeat<T>
where T: Clone,
Expand description

Create a stream which produces the same item repeatedly.

The stream never terminates. 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::stream::{self, StreamExt};

let stream = stream::repeat(9);
assert_eq!(vec![9, 9, 9], stream.take(3).collect::<Vec<i32>>().await);