rxjs - 具有相应 flatMap 结果的压缩值

假设我有一个文件流 filesStream 和一个函数 uploadFile ，它返回一个值流 (Rx.Observable.fromPromise(...))。流上的文件可以通过简单的 flatMap 上传:

filesStream.flatMap(uploadFile)

我需要的是从 filesStream 压缩文件，并使用 uploadFile 的相应响应:

zippedStream.subscribe(
    (file, response) => console.log("File " + file.name + " uploaded: " + response.message)
)

我想出了一个非常困惑的方法，但它确实有效

var zipppedStream = filesStream.flatMap(
    (file) => uploadFile(file).zip(Rx.Observable.just(file), (r, f) => [r, f])
)

但我真的不喜欢它，因为我需要在 subscribe 中解压二值数组，而且它通常看起来很重。
是你怎么做的还是我遗漏了什么？

最佳答案

您可以绕过使用 zip 并使用 flatMap 重载来完成您想要的这里

let zippedStream = fileStream.flatMap(
 (file) => uploadFile(file),
 (file, uploaded) => [file, uploaded]);

zippedStream.subscribe(
 ([file, response]) => console.log("File " + file.name + " uploaded: " + response.message));

关于rxjs - 具有相应 flatMap 结果的压缩值，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/30555709/