rx-java - 除非被打断，否则重复观察

Question

如何创建一个将重复n次的Observable，除非满足某些条件，然后它应该被中断？

看起来像repeatUnless或类似的运算符。

Answer 1

有两个选项:

1) 如果要中断值序列:

source.repeat(n).takeWhile(condition);
source.repeat(n).takeUntil(condition);

2) 如果要重复n次或直到不再满足条件:

source.repeatWhen(o -> o.scan(1, (a, b) -> a + 1).takeUntil(i -> i < n || condition)))