角2 rxjsタイムアウトコールバック

Question

HTTPコールのタイムアウトイベントが発生した場合、ユーザーにフィードバックを提供したいと考えています。

return this._http 
       .post(apiUrl + 'Search/Everything', params, {withCredentials: true, headers: this.headers}) 
       .timeout(5000, this._feedbackService.error("Custom error message")) 
       .map((response: Response) => response.json().data); 

しかし、それは、すぐにHTTP呼び出しが行われるようなフィードバックサービスを起動：

は、私はこれを試してみました。

タイムアウトが発生したときにサービスを開始するにはどうすればよいですか？ _feedbackService.errorはErrorを返すと仮定

Answer 1

、あなたはtimeoutWithと​​事業者と必要なものを行うことができる必要があります：

import "rxjs/add/observable‌​/defer"; 
import "rxjs/add/observable‌​/throw"; 
import "rxjs/add/operator/timeoutWith"; 
import { Observable } from "rxjs/Observable‌​"; 

return this._http 
    .post(apiUrl + 'Search/Everything', params, {withCredentials: true, headers: this.headers}) 
    .timeoutWith(5000, Observable.defer(() => Observable.throw(this._feedbackService.error("Custom error message")))) 
    .map((response: Response) => response.json().data);