我正在努力从Rx
Java迁移到
Java 8 lambdas.我找不到的一个例子是缓冲请求的方法.例如,在Rx Java中,我可以说如下.
Observable.create(getIterator()).buffer(20,1000,TimeUnit. MILLISECONDS).doOnNext(list -> doWrite(list));
我们将20个元素缓冲到一个列表中,或者以1000毫秒的时间超时,这首先发生.
RX中的可观测值是可观察的“推”样式,其中Streams使用java拉.这是否可能在流中实现我自己的地图操作,或者由于doOnNext必须轮询上一个元素,否则无法发出导致问题的原因?