Rxjava2019-03-26

每隔一秒执行list集合中的一条数据

// Observable listObservable = Observable.fromIterable(Catetorys);

//                //interval定时器，间隔1秒发射一次

//                Observable timerObservable = Observable.interval(1000, TimeUnit.MILLISECONDS);

//                //使用zip操作符合并两个Observable

//                Observable.zip(listObservable, timerObservable, new BiFunction() {

//                    @Override

//                    public MedicineCateBean apply(MedicineCateBean s, Long aLong) throws Exception {

//                        return s;

//                    }

//                }).doOnNext(new Consumer() {

//                    @Override

//                    public void accept(MedicineCateBean medicineCateBean) throws Exception {

//                        homePresenter.getHomeCategoryDetail(medicineCateBean.getActivityId(),1,10);

//                    }

//                }).subscribe();