Observable.timer(0, 2000)
.switchMap(() => Observable.if(
() => this.isBlocked,
Observable.defer(() => this.http.post(apiPath)
)
)
.catch(err => Observable.empty())
.subscribe((data: Array<any>) => {
this.notise = this.mapData(data);
});class SomeComponent {
private _isBlocked$$: Subject<boolean> = new Subject();
public isBlocked$: Observable<boolean> = this._isBlocked$$.asObservable();
public ngOnInit(): void {
this.isBlocked$
.switchMap((isBlocked: boolean) =>
isBlocked ? this.http.post(apiPath) : Observable.of(null))
.subscribe((data: Array<any>) => {
if (data !== null) {
this.notise = this.mapData(data);
}
});
}
public someMethod(bool: boolean): void {
this._isBlocked$$.next(bool);
}
}Observable.timer(0, 2000).takeUntil(this.isBlocked$)