promise - 如何将 Promise 数组转换为(Observables 的流？)

Question

假设我有一个 promise 数组，itemsPromises。其中一些会失败，一半可能会成功。

如果我尝试得到这样的响应:

const itemsPromises = raw.map(item =>
            axios({
                method:'get',
                url:`https://www.omdbapi.com/?apikey=${apikey}&i=${item.imdbID}`
            })
        )

const itemsResponses = wait Promise.all(itemsPromises)

...我需要等待很长时间，直到失败的 promise 最终超时。我可能会得到 5-6 个成功的回复，但在所有 promise 都得到解决或拒绝之前，我无法访问它们。

我可以将这个 Promise 数组转换为某种可迭代形式的 Observables，以便每次获得成功响应时我都可以将其传递到我的应用程序并使用它吗？

Answer 1

合并运算符让您可以同时执行每个 http 调用

Rx.Observable.merge(null,
raw.map(item =>
    Rx.Observable.fromPromise(axios({
        method: 'get',
        url: `https://www.omdbapi.com/?apikey=b54e8554&i=${item.imdbID}`
    })).catch(err=>Rx.Observable.of({err,item}))
)).subscribe()