android - 使用 RxAndroid，从网络接收数据后，我应该在哪里(用哪种方法)调用数据库中的数据插入部分？

Question

我从网络接收数据，我实现了那部分，但是在其他线程中从服务器接收数据后，我想将数据保存在数据库中，我不想在主线程中实现，所以在我接收到数据后应该调用数据库插入方法。这是我的代码

Observable<List<PhotoAlbum>> searchResponseObservable =
            mService.getAPI().getAlbums().subscribeOn(Schedulers.newThread())
                    .observeOn(AndroidSchedulers.mainThread());

    searchResponseObservable.subscribe(new Observer<List<PhotoAlbum>>() {
        @Override
        public void onCompleted() {
            Log.i("test","onComplete");
        }

        @Override
        public void onError(Throwable e) {
            Log.i("test","onComplete");
        }

        @Override
        public void onNext(List<PhotoAlbum> photoAlbums) {
            view().showSearchResult(photoAlbums);

        }
    });

Answer 1

您可以使用 doOnNext() 将收到的数据插入到您的数据库中，如下所示:

Observable<List<PhotoAlbum>> searchResponseObservable = mService.getAPI()
                        .getAlbums()
                        .subscribeOn(Schedulers.newThread())
                        .doOnNext(photoAlbums -> insertIntoDb(photoAlbums))
                        .observeOn(AndroidSchedulers.mainThread());

        searchResponseObservable.subscribe(new Observer<List<PhotoAlbum>>() {
            @Override
            public void onCompleted() {
                Log.i("test","onComplete");
            }

            @Override
            public void onError(Throwable e) {
                Log.i("test","onComplete");
            }

            @Override
            public void onNext(List<PhotoAlbum> photoAlbums) {
                view().showSearchResult(photoAlbums);
            }
        });