concat.js 413 B

1234567891011
  1. import { operate } from '../util/lift';
  2. import { concatAll } from './concatAll';
  3. import { popScheduler } from '../util/args';
  4. import { from } from '../observable/from';
  5. export function concat(...args) {
  6. const scheduler = popScheduler(args);
  7. return operate((source, subscriber) => {
  8. concatAll()(from([source, ...args], scheduler)).subscribe(subscriber);
  9. });
  10. }
  11. //# sourceMappingURL=concat.js.map