RxJS中的等待语句的执行

Question

我有以下陈述：

 for await (const blob of client.list()) {
    console.log('\t', blob.name);
}

client.list（）返回一个异步可迭代的迭代器，并期望使用for await...of来解决承诺。我想将代码合并到实例化客户端的现有rxjs管道中。

我到处都看了看，如果不解决管道内部的承诺而不是转换成可观察对象，就无法弄清楚该怎么做。

任何帮助将不胜感激！

Answer 1

我找不到现有的rxjs运算符，但创建自己的似乎并不难。将其他API与Observable集成时，可以在传递给Observable构造函数的函数中与API进行交互。触发下一个/错误/完成时，这提供了很大的灵活性。