rxjs observable debounceTime inner next 被忽略

Question

debounceTime 似乎忽略了对其主题 next 方法的内部调用:

var subject: Subject<number> = new Subject<number>();

subject.pipe(
    tap((a) => console.log("tab:" + a)), 
    debounceTime(300), 
).subscribe((a) => {
    console.log(a);
    subject.next(100)
});

subject.next(19);
subject.next(20);

上面的代码应该创建一个无限循环 - 但它没有:

tab:19
tab:20
20
tab:100

如果我将 delay(1) 添加到管道，它会按预期工作:

subject.pipe(
    tap((a) => console.log("tab:" + a)), 
    debounceTime(300), 
    delay(1)
).subscribe((a) => {
    console.log(a);
    subject.next(100)
});

我错过了什么吗？

编辑:添加示例:https://typescript-fbt2mn.stackblitz.io

Answer 1

这类问题似乎被破坏了，但可以使用 delay(0) 或 setTimeout 神奇地修复，这通常意味着您希望 RxJS一直异步运行，而实际上它通常同步运行，除非被迫以其他方式运行。

这正是你的情况。

• 当 debounce 推高它的值时，您就在这条线上 https://github.com/ReactiveX/rxjs/blob/5.5.10/src/operators/debounceTime.ts#L100 .

• 在 subscribe 中调用 next，它在 debounceTime 中到达 _next https://github.com/ReactiveX/rxjs/blob/5.5.10/src/operators/debounceTime.ts#L84它设置了 lastValue 和 hasValue 内部变量。

• 现在它开始在调用堆栈中向上移动，直到现在它才停止处理这一行 https://github.com/ReactiveX/rxjs/blob/5.5.10/src/operators/debounceTime.ts#L100 .此时它继续并再次覆盖 lastValue 和 hasValue https://github.com/ReactiveX/rxjs/blob/5.5.10/src/operators/debounceTime.ts#L101-L102 .这会将它们设置为 null 和 false。

• 然后在 300ms 之后 debounceTime 想要发出它的值但是 hasValue 是 null https://github.com/ReactiveX/rxjs/blob/5.5.10/src/operators/debounceTime.ts#L99因为它已经被覆盖了。

顺便说一句，一种更优雅的方法是将 observeOn 运算符与 async 调度程序一起使用，该调度程序的性能应该比 delay(1).

import { async } from 'rxjs/scheduler/async';

var obs = Observable.of(1, 2, 3);
var subject: Subject<number> = new Subject<number>();

subject.pipe(
    tap((a) => console.log("tab:" + a)), 
    debounceTime(300),
    observeOn(async),
).subscribe((a) => {
    console.log(a);
    subject.next(a+1)
});

看到你更新的演示:https://stackblitz.com/edit/typescript-tsek9s?file=index.ts

编辑:此行为可能在 RxJS 6 中发生了变化:https://github.com/ReactiveX/rxjs/pull/3218