RxJS5 - 等待 2 个 http 调用，然后监听套接字

Question

我有一个场景

1. 我需要调用 2 个 http 服务等待它们
2. 调用一些方法
3. 开始监听接下来会经常使用的套接字
4. 每次socket流，调用其他方法

如果重要的话，我正在使用 Angular2。

我现在拥有的是独立的（并且可以工作）。

我想知道如何在所有一系列运算符中创建它以保证等待前 2 个调用而不必使用本地变量？ - 如果这样做有意义的话......

我在做什么：

this.sub1 = Observable
    .forkJoin([http.get(/api1), http.get('/api2')])
        .subscribe(([api1ResData, api2ResData]) => {
            this.doSomething(api1ResData, api2ResData);
        });

this.sub2 = socket.get('api3')
    .subscribe(data => {
        this.doSomethingElse(api3ResData);
    });

Answer 1

如果this.doSomething(api1ResData, api2ResData)是一个返回Observable或Promise的异步函数，并且你想在下一个操作中使用该操作的结果，你可以使用switchMap或mergeMap将结果输出到另一个observable，然后订阅它以执行套接字操作，例如：

this.sub1 = Observable
.forkJoin([http.get(/api1), http.get('/api2')])
.switchMap(([api1ResData, api2ResData]) => {
    return this.doSomething(api1ResData, api2ResData)
})
.switchMap(doSomethingResult => {
    return socket.get('api3')
})
.subscribe(socketGetResult => {
    this.doSomethingElse(api3ResData);
});

如果this.doSomething(api1ResData, api2ResData) 同步返回另一个类型或为空，那么您可以只使用.do 运算符（如果您不需要doSomething 结果），或者.map，否则，如果您使用@ 987654330@ 导致socket.get(3)

this.sub1 = Observable
.forkJoin([http.get(/api1), http.get('/api2')])
.do(([api1ResData, api2ResData]) => {
   this.doSomething(api1ResData, api2ResData)
})
.switchMap(([api1res, api2res]) => {
    return socket.get('api3')
})
.subscribe(socketGetResult => {
    this.doSomethingElse(api3ResData);
});

您仍然使用switchMap 进行socket.get() 操作，因为您需要映射到另一个可观察对象，并接收之前的forkJoin 结果，因为.do 运算符是在不更改当前可观察对象的情况下执行代码。

查看switchMap official docs