相关疑难解决方法(0)

我正在寻找类似于exhaustMapfrom 运算符的东西rxjs，但RX.NET似乎没有这样的运算符。

我需要实现的是，在源流的每个元素上，我需要启动一个async处理程序，在它完成之前，我想从源中删除任何元素。处理程序完成后，立即恢复获取元素。

我不想在每个元素上启动一个异步处理程序——当处理程序运行时，我想删除源元素。

我还怀疑我需要在这里巧妙地使用 defer 运算符？

谢谢！