Ionic 3 & Firebase - 嵌套 observables 的正确方法

Question

有没有更实用的方法来用 RX/JS 嵌套这些 observables。这是一个 sn-p，我首先存储图像，然后返回下载 URL 并将其放入实时数据库中。

return new Observable(observer => {
        firebase.storage().ref().child('users/' + this.userService.getUserID() + '/messages/').put(image).then((data) => {

          updates['photoURL'] = data.downloadURL;

          firebase.database().ref().update(updates).then(() => {
            observer.next();
            observer.complete();
          }).catch((error) => {
            observer.error(error);
          })
        }, (error) => {
          observer.error(error);
        })
      });

Answer 1

您可以使用高阶 Observable 和 their respective operators 来内联相互依赖的操作。例如：

function uploadImageAndUpdateState(userId, image, updates) {
  return Observable.defer(() => firebase.storage().ref().child(`users/${userId}/messages/`).put(image))
    .mergeMap(imagePutData => {
      updates['photoURL'] = imagePutData.downloadURL;
      return firebase.database().ref().update(updates;
    });
});

通过在图像放置（承诺）上使用Defer()，此 Observable 将在订阅uploadImageAndUpdateState 以上传图像后启动，在从该操作接收数据后修改updates 并在 firebase 中更新它。由于您的示例不包含错误处理（仅传播），因此此函数中未完成此操作，您仍需要在 subscribe(.., onError => ???) 逻辑中自行处理。