从 observable 上的 finalize 方法返回一个 observable

Question

具体情况是这样的： AngularFirebase 文档说，为了从上传的文件中获取下载 URL，您需要这样做：

const task = this.storage.upload(filePath, file);

// observe percentage changes
// get notified when the download URL is available
task.snapshotChanges().pipe(
    finalize(() => this.downloadURL = fileRef.getDownloadURL() )
 )
.subscribe();
}

现在，我有一个上传方法，我想从它返回一个可观察的字符串。我的方法签名看起来像：

upload(file :File) :Observable<string> {

......

}

我试过这样做：

return <Observable<string>>task.snapshotChanges().pipe(
        finalize(() => {
            const url = fileRef.getDownloadURL();
            console.log('download url is ',url);
            return url;
        })
    );

但这不起作用，因为原始 observable 中还有其他类型的快照更改元素。

现在我的问题是，如何使用示例中的代码有效地返回我想要的类型

Answer 1

如文档中所述，finalize...

返回一个镜像源 Observable 的 Observable，但会在源因完成或错误终止时调用指定函数。

也就是说，你不能用传递的函数改变 Observable 类型。

相反，您可以结合使用 last 运算符和 map 运算符来获取映射到所需属性的最后一个值的通知。它看起来像这样：

return <Observable<string>>task.snapshotChanges().pipe(
        last(),
        map(() => {
            const url = fileRef.getDownloadURL();
            console.log('download url is ',url);
            return url;
        })
    );

Answer 2

我有同样的问题，这是我的解决方案

return <Observable<string>>task
      .snapshotChanges()
      .pipe(
        last(),
        flatMap(
          () => {
            return fileRef.getDownloadURL().pipe(
              map((url) => {
                return url;
              })
            );
          }
        )
      );