import { from } from 'rxjs' ; import { mergeMap } from 'rxjs/operators' ; import { IterableInput , AsyncMapFn } from './types' ; param iterable param fn export function map$ < T1 , T2 > ( iterable , fn ) { return from ( iterable ) . pipe ( mergeMap ( fn ) ) ; } param iterable param limit param fn export function mapWithLimit$ < T1 , T2 > ( iterable , limit , fn ) { return from ( iterable ) . pipe ( mergeMap ( fn , limit ) ) ; }