Наблюдаемое слияние с оператором трубы в RxJS версии 6 - PullRequest
Новая
       6

Наблюдаемое слияние с оператором трубы в RxJS версии 6

0 голосов
/ 17 декабря 2018

Я использую RxJS 6, который теперь использует оператор канала.У меня есть это: 

import {Observable, ReplaySubject} from 'rxjs';

const rs1 = new ReplaySubject(1); 
const rs2 = new ReplaySubject(1);
const rs3 = new ReplaySubject(1);

rs1.next(1);
rs2.next(2);
rs3.next(3);

Observable.merge(rs1,rs2,rs3).subscribe(v => {

});

, но это не компилируется - Observable.merge не определен.Я мог бы искать concat вместо слияния, но в любом случае concat также не определен как статический метод в конструкторе Observable - как мы можем использовать слияние и конкатат с RxJS7?

1 Ответ

0 голосов
/ 17 декабря 2018

Они изменили несколько вещей с версией 6, теперь это работает для меня: 

import {concat, Observable, merge} from 'rxjs';
import {BehaviorSubject, ReplaySubject, pipe} from "rxjs";
import {takeUntil, takeWhile} from 'rxjs/operators';


const rs1 = new ReplaySubject(1);  
const rs2 = new ReplaySubject(1);
const rs3 = new ReplaySubject(1);

rs1.next(1);
rs2.next(2);
rs3.next(2);

merge(rs1,rs2,rs3).pipe(takeWhile(() => true)).subscribe(v => {

  console.log({v});
});
...