Angular2 - 在另一个 Observable 中使用 Observable 返回方法的值

Question

问题

我不知道如何使用当前返回的getUserHeaders() 的Observable 的值|在我的 http.get .

当前错误

Type 'Observable<void>' is not assignable to type 'Observable<Participant[]>'

预期结果

能够使用我的 Observable 返回方法的值 getUserHeaders()作为 headers http 中的属性称呼。虽然只返回 http调用 Observable。

上一个代码

(与 getUserHeaders() 返回的硬编码 header 一起使用(因此不是 Observable 或 Promise )。

getAllParticipants(): Observable<Array<Participant>> {
    return this.http.get('someUrl',
                {headers: this.getUserHeaders()})
           .map(response => {
               return response.json();
        });
    });
   }

当前代码

路过Chaining RxJS Observables from http data in Angular2 with TypeScript的回答我来到了flatMap方法。 (注意此代码目前抛出“当前错误”)

getUserHeaders(): Observable<Headers> {
        let headers: Headers = new Headers();

        return NativeStorage.getItem("user").map(
            data => {
                headers.append('API_KEY', data.json().apiKey);
                headers.append('DEVICE_ID', data.json().deviceId);
                return headers
            }).catch( error => {
                console.log("error");
                headers.append('API_KEY', 'TEST');
                headers.append('DEVICE_ID', 'TEST');
                return headers;
            }
        );
    }

/** retrieves ALL the participants from the database */
    getAllParticipants(): Observable<Array<Participant>> {

         return this.getUserHeaders().flatMap( data => {
            return this.http.get('someUrl', {headers: data}).map(response => {
                return response.json();
            });
        });
   }

plunkr(Promise 而不是 Observable)

http://plnkr.co/edit/A0tEB9EUodWQS6AnqrtH?p=info

(注意:Observable.fromPromise() 在这里不起作用，所以我创建了两个返回 promise 的方法——现在我想在 getUserHeaders() 的 promise 中使用 getParticipants() 的值，并且仍然返回 promise /可观察getParticipants() 和 getUserHeaders() 中的任何内容

Answer 1

将您的 getUserHeaders() 更改为:

getUserHeaders(): Observable<any> { return Observable.of(NativeStorage.getItem("user"); }

然后在 getParticipants() 中构造您的 header 对象。这样你就可以保持 flatMap