Как получать данные периодически?

Question

[zlodiak]

Я в angular6-проекте пытаюсь получать данные через каждые 5 секунд. Написал сервис, но он не срабатывает.

JSFIDDLE

Помогите пожалуйста исправить код:

getExample(): Observable<any> {
    console.log('getExample');
    return Observable
      .timer(0, 5000)
      .flatMap(() => this.httpClient.get('https://jsonplaceholder.typicode.com/posts'))
      .map((r) => {
        return r;
      });
  }

При этом срабатывает более простой сервис - в котором нет интервала: JSFIDDLE

Answer 1

[Николай Болотников]

В RxJS 6 версии добавился оператор pipe, в котором следует изменять поток

import { Observable, timer } from 'rxjs';
import { flatMap } from 'rxjs/operators';

getExample(): Observable<any> {
    console.log('getExample');
    return timer(0, 5000).pipe(
        flatMap(() => this.httpClient.get('https://jsonplaceholder.typicode.com/posts'))
      )
  }