重复观察，除非被打断

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)))