Skip to content

Commit df0e058

Browse files
committed
Corrected typo in code
1 parent 0aa588f commit df0e058

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/mapGenerator.mjs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ import asyncIterableWrap from './asyncIterableWrap.mjs'
55
import getQueue from './getQueue.mjs'
66
import Queue from './Queue.mjs'
77
import reflectStatus from './reflectStatus.mjs'
8+
import queueMicrotask from './queueMicrotask.mjs'
89

910
/**
1011
* Produces a an async iterator that will return each value or `iterable` after having processed them through
@@ -75,9 +76,10 @@ async function * mapGenerator (iterable, iteratee, queueOrConcurrency = 1, order
7576
const waitList = new Map()
7677
const addToWaitList = (identifier, fct) => {
7778
const p = (async () => {
78-
return [identifier, await reflectStatus(fct)]
79+
const snapshot = await reflectStatus(fct)
80+
return [identifier, snapshot]
7981
})()
80-
assert(!waitList.has('identifier'), 'waitList already contains identifier')
82+
assert(!waitList.has(identifier), 'waitList already contains identifier')
8183
waitList.set(identifier, p)
8284
}
8385
const raceWaitList = async () => {

0 commit comments

Comments
 (0)