import { AsyncIterableX } from '../asynciterablex' ; import { as } from '../as' ; import { flatMap } from './flatmap' ; import { OperatorAsyncFunction } from '../../interfaces' ; template TSource returns { OperatorAsyncFunction < AsyncIterable < TSource > , TSource > } export function mergeAll < TSource > ( ) { return function mergeAllOperatorFunction ( source ) : AsyncIterableX < TSource > { return as ( source ) [ 'pipe' ] ( flatMap < AsyncIterable < TSource > , TSource > ( ( s ) => s ) ) ; } ; }