使用翻新和rxJava重复API调用

问题描述

我是RxJava的新手，我想使用改造来重复（3秒）API调用。我看到了一些答案，但我不知道该如何实现。

我遵循此link来重复通话。

这是我的代码

if (select==valuePath)

解决方法

这是我使用改型进行重复通话的方式

   compositeDisposable.add(Observable.interval(6,TimeUnit.SECONDS)
                .flatMap(n -> apiInterface.getTopRatedMovie(API_KEY))
                .repeat()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<MovieResopnse>() {
                    @Override
                    public void accept(MovieResopnse movieResopnse) throws Exception {
                        movies = movieResopnse.getResults();
                        Log.d(TAG,"onResponse: Number of movies received: " + movies.size());

                        doUIoperation();
                    }
                },this::onError));