如何改进Observable中的thread.sleep?

问题描述 投票:0回答:0

我想改进observable的doOnNext块里面的睡眠。

如果有更好的方法,请推荐一下。

Observable.from(sampleList)
                .buffer(5)
                .doOnNext(first -> {
                    // first Logic
                    try {
                        Thread.sleep(500);
                    } catch (InterruptedException e) {}
                })
                .buffer(2)
                .doOnNext(second -> {
                    // second Logic
                    try {
                        Thread.sleep(500);
                    } catch (InterruptedException e) {}
                })
                .buffer(2)
                .doOnNext(third -> {
                    // third Logic
                    try {
                        Thread.sleep(500);
                    } catch (InterruptedException e) {}
                })
                .subscribe();
observable rx-java thread-sleep
© www.soinside.com 2019 - 2024. All rights reserved.