javascript - RXJS：第一次拖动后捕获拖动事件不起作用

Question

我有这段代码，我试图在其中捕获所有拖动事件。此代码仅适用于第一次拖动和停止不适用于连续拖动。

是因为 takeUntil 取消了外部 observable 吗？我怎样才能使代码工作。

const { Observable, fromEvent } = rxjs;
const { takeUntil, switchMap } = rxjs.operators;

const mouseups = fromEvent(document.querySelector('.container'), 
'mouseup'); 
const mousedowns = fromEvent(document.querySelector('.container'), 
'mousedown');
const mousemoves = fromEvent(document.querySelector('.container'), 
'mousemove');

const source = mousedowns.pipe(
  switchMap(e => mousemoves),
  takeUntil(mouseups)
);

source.subscribe(e => console.log(e));

Answer 1

你需要把takeUntil里面的switchMap，像这样：

const source = mousedowns.pipe(
  switchMap(e => mousemoves.pipe(
    takeUntil(mouseups)
  ))
);

takeUntil放置在内部后，组合的 observable 将在事件发生时取消订阅observable mousemoves，mouseup但仍会订阅mousedownobservable。

放置在外面，它会mousedown在发生事件时取消订阅 observable mouseup- 这就是它在第一次拖动后停止响应的原因。