| 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 |