在后台线程中使用 blockingget 是否安全

Question

我基本上是想在后台将一个列表映射到 rxjava 中的一个字符串 thread.For 我使用阻塞的目的是 get.Is 它是安全的或者有更好的方法 it.Does 我在这里使用 blockingGet 松开我的异步？

 private Observable<Movie> getGenreObservable(Movie movie){
    return HttpCall.getRequest().getMovieGenres("").subscribeOn(Schedulers.io())
            .map(new Function<MovieGenreList, List<Genre>>() {
                @Override
                public List<Genre> apply(MovieGenreList movieGenreList) throws Throwable {
                    return movieGenreList.getGenres();
                }
            }).flatMap(new Function<List<Genre>, ObservableSource<List<Genre>>>() {
                @Override
                public ObservableSource<List<Genre>> apply(List<Genre> genres) throws Throwable {
                    return Observable.fromIterable(genres).filter(new Predicate<Genre>() {
                        @Override
                        public boolean test(Genre genre) throws Throwable {
                            for(Integer id:movie.getGenreIds()){
                                if(id == genre.getId()) return true;
                            }
                            return false;
                        }
                    }).toList().toObservable();
                }
            }).map(new Function<List<Genre>, List<String>>() {
                @Override
                public List<String> apply(List<Genre> genres) throws Throwable {
                    return Observable.fromIterable(genres).map(new Function<Genre, String>() {
                        public String apply(Genre genre) {
                            return genre.getName();
                        }
                    }).toList().blockingGet();
                }
            }).map(new Function<List<String>, String>() {
                @Override
                public String apply(List<String> strings) throws Throwable {
                    return Observable.fromIterable(strings).reduce(new BiFunction<String, String, String>() {
                        @Override
                        public String apply(String s, String s2) throws Throwable {
                            return s+", "+s2;
                        }
                    }).blockingGet();
                }
            }).map(new Function<String, Movie>() {
                @Override
                public Movie apply(String s) throws Throwable {
                    movie.setGenreNames(s);
                    return movie;
                }
            });
}

Answer 1

您可以只使用 .flatMap 而不是 .map，这样就不需要 blockingGet 了吗？

 private Observable<Movie> getGenreObservable(Movie movie){
    return HttpCall.getRequest().getMovieGenres("").subscribeOn(Schedulers.io())
            .map(new Function<MovieGenreList, List<Genre>>() {
                @Override
                public List<Genre> apply(MovieGenreList movieGenreList) throws Throwable {
                    return movieGenreList.getGenres();
                }
            }).flatMap(new Function<List<Genre>, ObservableSource<List<Genre>>>() {
                @Override
                public ObservableSource<List<Genre>> apply(List<Genre> genres) throws Throwable {
                    return Observable.fromIterable(genres).filter(new Predicate<Genre>() {
                        @Override
                        public boolean test(Genre genre) throws Throwable {
                            for(Integer id:movie.getGenreIds()){
                                if(id == genre.getId()) return true;
                            }
                            return false;
                        }
                    }).toList().toObservable();
                }
            }).flatMap(new Function<List<Genre>, Observable<List<String>>>() {
                @Override
                public List<String> apply(List<Genre> genres) throws Throwable {
                    return Observable.fromIterable(genres).map(new Function<Genre, String>() {
                        public String apply(Genre genre) {
                            return genre.getName();
                        }
                    }).toList();
                }
            }).flatMap(new Function<List<String>, Observable<String>>() {
                @Override
                public String apply(List<String> strings) throws Throwable {
                    return Observable.fromIterable(strings).reduce(new BiFunction<String, String, String>() {
                        @Override
                        public String apply(String s, String s2) throws Throwable {
                            return s+", "+s2;
                        }
                    })
                }
            }).map(new Function<String, Movie>() {
                @Override
                public Movie apply(String s) throws Throwable {
                    movie.setGenreNames(s);
                    return movie;
                }
            });
}

在后台线程中使用 blockingget 是否安全

Is blockingget safe to use in background thread

android

rx-java