javascript - 为什么 `finally` 在这种情况下在 RxJS 中不起作用？

Question

这不会打印“drag end”:

mouseDrags.forEach(drag => {
    console.log('drag start');
    drag.finally(_ => console.log('drag end'));
    drag.forEach(doSomething);
});

但这会打印“drag end”:

mouseDrags.forEach(drag => {
    console.log('drag start');
    drag.finally(_ => console.log('drag end')).forEach(_=>_);
    drag.forEach(doSomething);
});

为什么 forEach 会有所不同？

Answer 1

这是因为.finally()返回了另一个你需要订阅的Observable。 Observable 默认情况下是惰性的，因此在被订阅之前它们不会开始发射。

所以你可以这样做

mouseDrags.forEach(drag => {
    console.log('drag start');
    drag.finally(_ => console.log('drag end')).forEach(doSomething);
});

甚至更好

mouseDrags.flatMap(drag => {
    console.log('drag start');
    return drag.finally(_ => console.log('drag end'))  
}).forEach(doSomething);