add iterator and asyncIterator forEach helpers

Author: zth

CHANGELOG.md

@@ -2,6 +2,7 @@
 
 ## Next version
 
+- Add `Iterator.forEach` and `AsyncIterator.forEach` helpers for iterators.
 - Add `Dict.getUnsafe` https://github.com/rescript-association/rescript-core/pull/167
 
 ### Documentation

src/Core__AsyncIterator.mjs

@@ -1,2 +1,17 @@
 // Generated by ReScript, PLEASE EDIT WITH CARE
-/* This output is empty. Its source's type definitions, externals and/or unused code got optimized away. */
+
+import * as Curry from "rescript/lib/es6/curry.js";
+
+async function forEach(iterator, f) {
+  var iteratorDone = false;
+  while(!iteratorDone) {
+    var match = await iterator.next();
+    Curry._1(f, match.value);
+    iteratorDone = match.done;
+  };
+}
+
+export {
+  forEach ,
+}
+/* No side effect */

src/Core__AsyncIterator.res

@@ -6,3 +6,13 @@ type value<'a> = {
 }
 
 @send external next: t<'a> => promise<value<'a>> = "next"
+
+let forEach = async (iterator, f) => {
+  let iteratorDone = ref(false)
+
+  while !iteratorDone.contents {
+    let {done, value} = await iterator->next
+    f(value)
+    iteratorDone := done
+  }
+}

src/Core__AsyncIterator.resi

@@ -57,3 +57,19 @@ let processMyAsyncIterator = async () => {
 */
 @send
 external next: t<'a> => promise<value<'a>> = "next"
+
+/**
+`forEach(iterator, fn)` consumes all values in the async iterator and runs the callback `fn` for each value.
+
+See [iterator protocols](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols) on MDN.
+
+## Examples
+```rescript
+await someAsyncIterator->AsyncIterator.forEach(value => {
+  if value > 10 {
+    Console.log("More than 10!")
+  }
+})
+```
+*/
+let forEach: (t<'a>, option<'a> => unit) => promise<unit>

src/Core__Iterator.mjs

@@ -1,2 +1,17 @@
 // Generated by ReScript, PLEASE EDIT WITH CARE
-/* This output is empty. Its source's type definitions, externals and/or unused code got optimized away. */
+
+import * as Curry from "rescript/lib/es6/curry.js";
+
+function forEach(iterator, f) {
+  var iteratorDone = false;
+  while(!iteratorDone) {
+    var match = iterator.next();
+    Curry._1(f, match.value);
+    iteratorDone = match.done;
+  };
+}
+
+export {
+  forEach ,
+}
+/* No side effect */

src/Core__Iterator.res

@@ -8,3 +8,13 @@ type value<'a> = {
 @send external next: t<'a> => value<'a> = "next"
 external toArray: t<'a> => array<'a> = "Array.from"
 external toArrayWithMapper: (t<'a>, 'a => 'b) => array<'b> = "Array.from"
+
+let forEach = (iterator, f) => {
+  let iteratorDone = ref(false)
+
+  while !iteratorDone.contents {
+    let {done, value} = iterator->next
+    f(value)
+    iteratorDone := done
+  }
+}

src/Core__Iterator.resi

@@ -78,3 +78,19 @@ Console.log(mapKeysAsArray) // Logs [7, 8] to the console.
 ```
 */
 external toArrayWithMapper: (t<'a>, 'a => 'b) => array<'b> = "Array.from"
+
+/**
+`forEach(iterator, fn)` consumes all values in the iterator and runs the callback `fn` for each value.
+
+See [iterator protocols](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols) on MDN.
+
+## Examples
+```rescript
+someIterator->Iterator.forEach(value => {
+  if value > 10 {
+    Console.log("More than 10!")
+  }
+})
+```
+*/
+let forEach: (t<'a>, option<'a> => unit) => unit

test/ArrayTests.mjs

@@ -450,7 +450,7 @@ Test.run([
 Test.run([
       [
         "ArrayTests.res",
-        109,
+        112,
         20,
         39
       ],
@@ -464,7 +464,7 @@ Test.run([
 Test.run([
       [
         "ArrayTests.res",
-        110,
+        113,
         20,
         34
       ],

test/IteratorTests.mjs

@@ -0,0 +1,77 @@
+// Generated by ReScript, PLEASE EDIT WITH CARE
+
+import * as Test from "./Test.mjs";
+import * as Caml_obj from "rescript/lib/es6/caml_obj.js";
+import * as Core__Iterator from "../src/Core__Iterator.mjs";
+import * as Core__AsyncIterator from "../src/Core__AsyncIterator.mjs";
+
+var eq = Caml_obj.equal;
+
+var iterator = ((() => {
+    var array1 = ['a', 'b', 'c'];
+    var iterator1 = array1[Symbol.iterator]();
+    return iterator1
+  })());
+
+var syncResult = {
+  contents: undefined
+};
+
+Core__Iterator.forEach(iterator, (function (v) {
+        if (v === "b") {
+          syncResult.contents = "b";
+          return ;
+        }
+        
+      }));
+
+Test.run([
+      [
+        "IteratorTests.res",
+        21,
+        20,
+        34
+      ],
+      "Sync forEach"
+    ], syncResult.contents, eq, "b");
+
+var asyncIterator = ((() => {
+    var map1 = new Map();
+
+    map1.set('first', '1');
+    map1.set('second', '2');
+
+    var iterator1 = map1[Symbol.iterator]();
+    return iterator1;
+  })());
+
+var asyncResult = {
+  contents: undefined
+};
+
+await Core__AsyncIterator.forEach(asyncIterator, (function (v) {
+        if (v !== undefined && v[0] === "second") {
+          asyncResult.contents = "second";
+          return ;
+        }
+        
+      }));
+
+Test.run([
+      [
+        "IteratorTests.res",
+        44,
+        20,
+        35
+      ],
+      "Async forEach"
+    ], asyncResult.contents, eq, "second");
+
+export {
+  eq ,
+  iterator ,
+  syncResult ,
+  asyncIterator ,
+  asyncResult ,
+}
+/* iterator Not a pure module */

test/IteratorTests.res

@@ -0,0 +1,44 @@
+open RescriptCore
+
+let eq = (a, b) => a == b
+
+let iterator: Iterator.t<string> = %raw(`
+  (() => {
+    var array1 = ['a', 'b', 'c'];
+    var iterator1 = array1[Symbol.iterator]();
+    return iterator1
+  })()
+`)
+
+let syncResult = ref(None)
+
+iterator->Iterator.forEach(v => {
+  if v === Some("b") {
+    syncResult.contents = Some("b")
+  }
+})
+
+Test.run(__POS_OF__("Sync forEach"), syncResult.contents, eq, Some("b"))
+
+let asyncIterator: AsyncIterator.t<(string, string)> = %raw(`
+  (() => {
+    var map1 = new Map();
+
+    map1.set('first', '1');
+    map1.set('second', '2');
+
+    var iterator1 = map1[Symbol.iterator]();
+    return iterator1;
+  })()
+`)
+
+let asyncResult = ref(None)
+
+await asyncIterator->AsyncIterator.forEach(v => {
+  switch v {
+  | Some(("second", _value)) => asyncResult.contents = Some("second")
+  | _ => ()
+  }
+})
+
+Test.run(__POS_OF__("Async forEach"), asyncResult.contents, eq, Some("second"))

test/TestSuite.mjs

@@ -1,13 +1,15 @@
 // Generated by ReScript, PLEASE EDIT WITH CARE
 
 import * as IntTests from "./IntTests.mjs";
+import * as DictTests from "./DictTests.mjs";
 import * as TestTests from "./TestTests.mjs";
 import * as ArrayTests from "./ArrayTests.mjs";
 import * as ErrorTests from "./ErrorTests.mjs";
 import * as FloatTests from "./FloatTests.mjs";
 import * as ObjectTests from "./ObjectTests.mjs";
 import * as PromiseTest from "./PromiseTest.mjs";
 import * as ResultTests from "./ResultTests.mjs";
+import * as IteratorTests from "./IteratorTests.mjs";
 import * as TypedArrayTests from "./TypedArrayTests.mjs";
 
 var bign = TestTests.bign;
@@ -64,7 +66,15 @@ var areSame = TypedArrayTests.areSame;
 
 var o = TypedArrayTests.o;
 
-var eq = FloatTests.eq;
+var eq = IteratorTests.eq;
+
+var iterator = IteratorTests.iterator;
+
+var syncResult = IteratorTests.syncResult;
+
+var asyncIterator = IteratorTests.asyncIterator;
+
+var asyncResult = IteratorTests.asyncResult;
 
 export {
   bign ,
@@ -95,5 +105,9 @@ export {
   areSame ,
   o ,
   eq ,
+  iterator ,
+  syncResult ,
+  asyncIterator ,
+  asyncResult ,
 }
 /* IntTests Not a pure module */

test/TestSuite.res

@@ -7,3 +7,5 @@ include ObjectTests
 include ResultTests
 include TypedArrayTests
 include FloatTests
+include DictTests
+include IteratorTests