rong 0.2.0

use futures::stream;
use rong_test::*;

#[test]
fn iterator_sync() {
    run(|ctx: &JSContext| {
        ctx.global()
            .set("print", JSFunc::new(ctx, |msg: String| println!("{}", msg)))?;

        let data = vec![1, 2, 3, 4, 5];
        let iterator = JSFunc::new(ctx, move |ctx: JSContext| data.clone().to_js_iter(&ctx));

        ctx.global().set("iterator", iterator)?;
        let result: i32 = ctx.eval(Source::from_bytes(
            r#"
            for (const n of iterator()) {
                 print(n.toString());
            }
            let sum=0;
            for (const n of iterator()) {
                 print(n.toString());
                 sum+=n;
            }
            sum
            "#,
        ))?;
        assert_eq!(result, 15);
        Ok(())
    });
}

#[test]
fn iterator_async() {
    async_run!(async |ctx: JSContext| {
        ctx.global().set(
            "print",
            JSFunc::new(&ctx, |msg: String| println!("{}", msg)),
        )?;

        let data = stream::iter(1..=5);
        let iterator = JSFunc::new(&ctx, move |ctx: JSContext| {
            data.clone().to_js_async_iter(&ctx)
        })?;

        ctx.global().set("iterator", iterator)?;
        let result: i32 = ctx
            .eval_async(Source::from_bytes(
                r#"
            print(typeof iterator()[Symbol.asyncIterator]);
            (async function () {
                for await (const n of iterator()) {
                   print(n.toString());
                }
                let sum=0;
                for await (const n of iterator()) {
                    print(n.toString());
                    sum+=n;
                }
                return sum;
            })()
            "#,
            ))
            .await?;
        assert_eq!(result, 15);
        Ok(())
    });
}