Как переписать слияние на новые Rxjs? - PullRequest
0 голосов
/ 29 октября 2019

У меня есть старое слияние Rxjs:

Observable.merge(this.timers).subscribe(x => {
      let subscription = x.subscribe((value: ITimer) => {});

});

Как переписать его в новой записи Rxjs?

Я попытался импортировать это:

import { merge } from "rxjs/operators";

1 Ответ

2 голосов
/ 29 октября 2019

Как вы можете видеть: merge все еще является частью rxjs, он не живет как оператор ... Это просто фабрика, из которой вы можете создать новую наблюдаемую из n ...

const { merge, from } = rxjs;

const a$ = from([1, 2, 3, 4]);
const b$ = from(['hello', 'world', 'dude']);

merge(a$, b$).subscribe(console.log);
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.5.3/rxjs.umd.js" integrity="sha256-Nihli32xEO2dsnrW29M+krVxoeDblkRBTkk5ZLQJ6O8=" crossorigin="anonymous"></script>
...