Adds asyncFilterObject, asyncFindKey, asyncForEachObject and

asyncGroupBy

src/asyncFilterObject.mjs

@@ -0,0 +1,15 @@
+
+import Queue from './Queue.mjs'
+import asyncFromEntries from './asyncFromEntries.mjs'
+import asyncGeneratorFilter from './asyncGeneratorFilter.mjs'
+import generatorEntries from './generatorEntries.mjs'
+import asyncWrap from './asyncWrap.mjs'
+
+async function asyncFilterObject (obj, iteratee, queueOrConcurrency = 1) {
+  iteratee = asyncWrap(iteratee)
+  return await asyncFromEntries(asyncGeneratorFilter(generatorEntries(obj), async ([k, v]) => {
+    return await iteratee(v, k, obj)
+  }, queueOrConcurrency))
+}
+
+export default asyncFilterObject

src/asyncFindKey.mjs

@@ -0,0 +1,14 @@
+
+import asyncFindInternal from './asyncFindInternal.mjs'
+import generatorEntries from './generatorEntries.mjs'
+import Queue from './Queue.mjs'
+
+async function asyncFindKey (obj, iteratee, queueOrConcurrency = 1, ordered = false) {
+  iteratee = asyncWrap(iteratee)
+  const [k, _] = (await asyncFindInternal(generatorEntries(obj), async ([k, v]) => {
+    return await iteratee(v, k, obj)
+  }, queueOrConcurrency, ordered))[1]
+  return k
+}
+
+export default asyncFindKey

src/asyncForEachObject.mjs

@@ -0,0 +1,16 @@
+
+import asyncGeneratorMap from './asyncGeneratorMap.mjs'
+import generatorEntries from './generatorEntries.mjs'
+import Queue from './Queue.mjs'
+
+async function asyncForEachObject (obj, iteratee, queueOrConcurrency = 1) {
+  iteratee = asyncWrap(iteratee)
+  // eslint-disable-next-line no-unused-vars
+  for await (const _el of asyncGeneratorMap(generatorEntries(obj), async ([k, v]) => {
+    await iteratee(v, k, obj)
+  }, queueOrConcurrency, false)) {
+    // do nothing
+  }
+}
+
+export default asyncForEachObject

src/asyncGroupBy.mjs

@@ -0,0 +1,22 @@
+
+import asyncGeneratorMap from './asyncGeneratorMap.mjs'
+import asyncWrap from './asyncWrap.mjs'
+import Queue from './Queue.mjs'
+
+async function asyncGroupBy (iterable, iteratee, queueOrConcurrency = 1) {
+  interatee = asyncWrap(iteratee)
+  const groups = {}
+  for await (const [group, value] of asyncGeneratorMap(iterable, async (v, i, it) =>
+    {
+      const group = await iteratee(v, i, it)
+      return [group, v]
+    }, queueOrConcurrency))
+  {
+    if (!(group in groups))
+    {
+      groups[group] = []
+    }
+    groups[group].push(value)
+  }
+  return groups
+}