获得可观察性，但在激活之前等待承诺

Question

在使用 RxJS 在 Angular 2 中激活 observable 之前，我需要等待 promise 完成。

更具体地说，我需要使用返回承诺的第三方库设置状态，并在发出 GET 请求之前将一些结果信息插入到我的 HTTP 标头中：

export class LiveDataService {

    private headersPromise;

    constructor(public http: Http) {
        this.headersPromise = $.connection('/init').then((state) => setupHeaders(state));
    }

    activate(route: string) {
        return this.http.get('api/v1/' + route, { headers })
            .Merge(anotherStateBasedObservable);
    }

)

除了，虽然我需要如图所示立即返回 observable，但在调用 http.get 之前，我还必须等待 promise 完成。

我可以想到一些需要 3-4 个翻译阶段的方法，但我觉得应该有一个相当直接的方法来做到这一点。

Answer 1

你真的需要一个 observable 来返回吗？我会这样做：

// getState caches the state promise, so '/init' gets requested only once
// but is lazy loaded
var _statePromise = null;
function getState() {
  return _statePromise || (_statePromise = $.connection('/init'));
}

function routeChange(route) {
  return getState()
    .then(state => setupHeaders(state))
    .then(headers => this.http.get('api/v1/' + route, { headers }));
}

编辑

您可以使用 flatMap 或 flatMapLatest 使用异步函数映射 observable：

// routeSource is an RxJS Observable
var contentSource = routeSource.flatMapLatest(routeChange);

编辑

您可以将 Promise 转换为 observables，反之亦然：Bridging Promises

这可能是你需要的：

// getState caches the state promise, so '/init' gets requested
// only once, but is lazy loaded
var _statePromise = null;
function getState() {
  return _statePromise || (_statePromise = $.connection('/init'));
}
function Method(route) {
  return Rx.Observable.fromPromise(this.getState())
    .flatMap(state => setupHeaders(state)) // flatMap handles promises
    .flatMap(headers => this.http.get('api/v1/' + route, { headers }))
    .merge(anotherStateBasedObservable);
}