0

我试图每秒调用我的 API。我不知道该怎么做。

准时通话是可以的:

loadRequest(payload: any): Observable<RequestTask[]> {
    const headers = new Headers({'Authorization': localStorage.getItem('authorizationToken')});
    const options = new RequestOptions({headers: headers});
    const requestId = payload;
    const url = '/api/requests/'+ requestId +'/events'

    return this.http
        .get(url, options)
        .map(response => {
            const requests = response.json();
            console.log("Request API", requests)
            return requests.map(request => {
                return new RequestTask(request)
            });
        })
        .catch(this.handleError);
}

我对每秒通话的测试

loadRequest(payload: any): Observable<RequestTask[]> {
    const headers = new Headers({'Authorization': localStorage.getItem('authorizationToken')});
    const options = new RequestOptions({headers: headers});
    const requestId = payload;
    const url = '/api/requests/'+ requestId +'/events'

    return Observable.interval(500)
        .flatMap(()=> {
            return this.http
                .get(url, options)
                .map(response => {
                    const request = response.json();
                    return request.map(request => {
                        return new RequestTask(request)
                    });
                }).catch(this.handleError);
        })

}

我认为我的错误来自 Observable 但我不知道如何解决它

4

0 回答 0