如何使用RxPY重写RxJS倒计时器并排查代码运行异常？

• 核心错误是RxJS的mapTo(-1)逻辑被错误实现：mapTo的作用是无论上游发射什么值，都统一映射为固定的常量值，原RxJS逻辑是每次定时器触发都给累计值加-1，实现递减效果。
• 你编写的RxPY代码中用了ops.map(lambda value: value - 1)，这里的value是rx.interval(1)发射的递增序列：0、1、2、3……，映射后得到的是-1、0、1、2……，和scan的初始值10累加自然就变成了非递减的错误结果。

RxPY没有内置的mapTo操作符，直接用map返回固定值-1即可等效实现，修正后代码如下：

import rx
from rx import operators as ops

counter = rx.interval(1)
composed = counter.pipe(
    # 忽略上游发射的数值，统一映射为-1，和RxJS mapTo(-1)逻辑完全对齐
    ops.map(lambda _: -1),
    ops.scan(lambda acc, curr: acc + curr, 10),
    ops.take_while(lambda value: value >= 0),
)
composed.subscribe(lambda value: print(value))

运行后会依次输出9、8、7……0，和原RxJS实现的倒计时效果完全一致。

内容的提问来源于stack exchange，提问作者melkir