RxJava CountDownTimer RxJava实现倒计时

//倒计时10-1    
Observable.interval(1, TimeUnit.SECONDS)
                .take(10) // up to 10 items
                .map(new Function<Long, Long>() {
                    @Override
                    public Long apply(Long v) throws Exception {
                        return 10 - v;
                    }
                })
                .subscribeOn(Schedulers.computation())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<Long>() {
                    @Override
                    public void onSubscribe(@NonNull Disposable d) {
                        // on start
                    }

                    @Override
                    public void onNext(@NonNull Long aLong) {
                        Log.i(TAG, "count down : aLong=" + aLong);
                      
                    }

                    @Override
                    public void onError(@NonNull Throwable e) {

                    }

                    @Override
                    public void onComplete() {                     
                        Log.i(TAG, "----------倒计时结束------------");
                    }
                });
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容