一种方法是
zip将可观察值与
Interval可观察值结合起来以延迟输出。
Observable.zip(Observable.range(1, 5) .groupBy(n -> n % 5) .flatMap(g -> g.toList()), Observable.interval(50, TimeUnit.MILLISECONDS), (obs, timer) -> obs) .doonNext(item -> { System.out.println(System.currentTimeMillis() - timeNow); System.out.println(item); System.out.println(" "); }).toList().toBlocking().first();
