angular - 我没有得到 rxjs 6 和 angular 6 的间隔、switchMap 和 map

Question

我想将我的 rxjs 代码更新为 6，但我不明白。

在我得到以下内容之前，每 5 秒轮询一次新数据：

import { Observable, interval } from 'rxjs';
import { switchMap, map } from 'rxjs/operators';

var result = interval(5000).switchMap(() => this._authHttp.get(url)).map(res => res.json().results);

现在......当然，它坏了，文档让我无处可去。

我如何编写以上内容以符合 rxjs 6？

谢谢

标签： angularrxjsrxjs6

Answer 1

代码应该类似于以下内容。您需要使用pipe运算符。

import { interval } from 'rxjs';
import { switchMap, map } from 'rxjs/operators';

const result = interval(5000).pipe(
switchMap(() => this._authHttp.get(url)),    
map(res => res.results)
)