use crate::{ops::GeneratorState, rc::Gen};
use std::future::Future;
impl<Y, F: Future<Output = ()>> IntoIterator for Gen<Y, (), F> {
type Item = Y;
type IntoIter = IntoIter<Y, F>;
#[must_use]
fn into_iter(self) -> Self::IntoIter {
IntoIter { generator: self }
}
}
pub struct IntoIter<Y, F: Future<Output = ()>> {
generator: Gen<Y, (), F>,
}
impl<Y, F: Future<Output = ()>> Iterator for IntoIter<Y, F> {
type Item = Y;
fn next(&mut self) -> Option<Self::Item> {
match self.generator.resume() {
GeneratorState::Yielded(x) => Some(x),
GeneratorState::Complete(()) => None,
}
}
}
#[cfg(test)]
mod tests {
use crate::rc::{Co, Gen};
use std::iter::IntoIterator;
async fn produce(co: Co<i32>) {
co.yield_(10).await;
co.yield_(20).await;
}
#[test]
fn into_iter() {
let gen = Gen::new(produce);
let items: Vec<_> = gen.into_iter().collect();
assert_eq!(items, [10, 20]);
}
#[test]
fn for_loop() {
let mut sum = 0;
for x in Gen::new(produce) {
sum += x;
}
assert_eq!(sum, 30);
}
}