Ваш код будет выглядеть примерно так:
import {interval, Observable} from 'rxjs';
import {flatMap, map} from 'rxjs/operators';
getHeroes(): Observable<Hero[]> {
interval(500)
.pipe(
flatMap(() => this.http
.get(this.heroesUrl)
.pipe(map(data => data.json()))
})
);
}
Идея проста;все Observable
, Subject
, .. и методы, которые создают наблюдаемые, импортируются непосредственно из rxjs
.И вы больше не можете просто связывать операторы на наблюдаемом объекте, вам нужно использовать метод pipe
и поместить все свои операторы туда.Операторы импортируются из rxjs/operators
Sidenote, поскольку вы делаете data.json()
Я предполагаю, что вы все еще используете "старые" методы http, вам следует вместо этого начать использовать httpClient.get
(https://angular.io/api/common/http/HttpClient)
Кроме того, при обновлении до Rxjs 6 вы можете установить скрипт миграции, который фактически делает это автоматически для вас