java - 可观察超时

Question

假设我有以下内容。

Observable.range(1,1000)
.flatMap(i -> Observable.just(i)
    .subscribeOn(Schedulers.computation()
    .map(i2 -> calculate(i2))
).subscribe(System.out::println)

在这里我有一个从 1 到 1000 的可观察值，每个数字都在不同的线程中使用 calculate()(一个大方法)映射。我需要设置一个超时，直到返回一定数量的项目。

假设我有 2 秒的超时。

我需要订阅 2-50 条。(至少订阅 2 条，但不超过 50 条)

如果 2 项在 2 秒内未发出，则重启超时。

假设在超时内返回了 10 个项目。然后执行其余代码没问题。

我如何使用 Rx Java 执行此操作？

Answer 1

这可以在 rx-java 中使用 buffer() 而不是使用 timeout() 来实现