map an asynchronous function? about itiriri-async HOT 2 OPEN

Quick update: I did find a workaround with .flat() but it's kinda gnarly.

seq.flat(async function* (x) { yield await f(x) })

Surely seq.map(f) would be way nicer.

And this workaround is especially unpleasant if f needs to access this, as one can't use an arrow function to create a generator.

EDIT: and unfortunately, the overload for .flat() that takes a transformation returns a plain AsyncIterable and not an AsyncIterableQuery, so I can't continue to chain itiriri methods together after using the workaround without wrapping up with itiririAsync again.

from itiriri-async.

Hi @tsani,
I don't remember the exact implementation, but from the source code here it looks like map accepts async functions as well.

So in the case of:

(selector: (x: T) => S): AsyncIterableQuery<S>

the selector can be a function that returns a Promise. I agree typings have to be fixed.
It should look like:

(selector: (x: T) => S | Promise<S>): AsyncIterableQuery<S>

You're welcome to open a PR.

from itiriri-async.