import { mergeMap } from './mergeMap'; | |
export function mergeMapTo(innerObservable, resultSelector, concurrent = Number.POSITIVE_INFINITY) { | |
if (typeof resultSelector === 'function') { | |
return mergeMap(() => innerObservable, resultSelector, concurrent); | |
} | |
if (typeof resultSelector === 'number') { | |
concurrent = resultSelector; | |
} | |
return mergeMap(() => innerObservable, concurrent); | |
} | |
//# sourceMappingURL=mergeMapTo.js.map |