import { IParallelEnumerable , TypedData } from "../../types" ; import { BasicParallelEnumerable } from "../BasicParallelEnumerable" ; import { nextIterationAsync } from "./_nextIterationAsync" ; param source param action returns export const eachAsync = < TSource > ( source , action ) : IParallelEnumerable < TSource > => { const dataFunc = nextIterationAsync ( source , async ( x ) => { await action ( x ) ; return x ; } ) ; return new BasicParallelEnumerable ( dataFunc ) ; } ;