Angular2-可观测返回方法在另一个可观测中的使用价值

Question

我不知道如何在我的http中使用当前返回的getUserHeaders（）的可观察值。获取。

类型“可观察”

能够将我的可观察返回方法getUserHeaders（）的值用作http调用中的headers属性。而只返回http调用的可观察值。

（它使用由getUserHeaders（）返回的harcoded头（因此不是可观察的或promise的）。

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

通过用TypeScript的答案从Angular2中的超文本传输协议数据中链接RxJS可观测数据，我来到了平板地图方法。（请注意，这段代码当前抛出了“当前错误”）

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();
            });
        });
   }

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

（注意：Observable.fromPromise（）在这里不起作用，所以我创建了两个返回promise的方法-现在我想使用getUserHeaders（）的值在get参与者（）和仍然返回的promise/可观察的get参与者（）和没有从getUserHeaders（）




Answer 1

就个人而言，我的问题的解决方案是使用行为主体：

在用（数据来源）：

private theBoolean: BehaviorSubject<boolean>;

constructor() {
    this.theBoolean = new BehaviorSubject<boolean>(false);
}

public getTheBoolean(): Observable<boolean> {
    return this.theBoolean.asObservable();
}

发出布尔值的新值

public setTheBoolean(newValue: boolean): void {
    this.theBoolean.next(newValue);
}

在组件中（数据的用户）：

this.theService.getTheBoolean().subscribe(value => console.log(value));

Reddit上的“pashozator”功劳

Answer 2

将您的getUserHeaders（）更改为：

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

然后构造你的头对象在get参与者（）。这样，您可以保持平面地图