1

これがRxPYで再現しようとしているRxJSコードです。

const counter$ = interval(1000);
counter$
  .pipe(
    mapTo(-1),
    scan((accumulator, current) => {
      return accumulator + current;
    }, 10),
    takeWhile(value => value >= 0)
  )
  .subscribe(console.log);

9
8
7
6
5
4
3
2
1
0
-1

そして、これは私が同等だったものですが、そうではありません

counter = rx.interval(1)
composed = counter.pipe(
    ops.map(lambda value: value - 1),
    ops.scan(lambda acc, curr: acc + curr, 10),
    ops.take_while(lambda value: value >= 0),
)
composed.subscribe(lambda value: print(value))

9
9
10
12
15
19

誰かが私がここで欠けているものを理解するのを手伝ってくれますか?

4

1 に答える 1