RxJava-模拟进度

//0-100 每隔20ms +1
Observable.just(100)
        .flatMap(new Func1<Integer, Observable<Long>>() {
            @Override
            public Observable<Long> call(Integer integer) {
                return Observable.timer(20, TimeUnit.MILLISECONDS);
            }
        })
        .compose(RxHelper.<Long>io_main())
        .subscribe(new Subscriber<Long>() {
            @Override
            public void onCompleted() {
  
            }
  
            @Override
            public void onError(Throwable e) {
  
            }
  
            @Override
            public void onNext(Long aLong) {
                pb.setProgress(aLong.intValue());
            }
        });

应用场景

• 计时器
• 进度模拟
• 定时任务