[java] RxJava에서 언제 map vs flatMap을 사용합니까?

내가 생각하는 방식 flatMap은 내부에 넣고 싶은 함수가를 map()반환 할 때 사용한다는 것 Observable입니다. 이 경우에도 여전히 사용하려고 map()하지만 실용적이지 않습니다. 이유를 설명하려고 노력하겠습니다.

그러한 경우에 고집하기로 결정 map했다면 Observable<Observable<Something>>. 예를 들어, 가상의 RxGson 라이브러리를 사용했다면 (그냥 단순히 반환하는 대신) 메소드 Observable<String>에서 를 반환하면 다음과 같습니다.toJson()String

Observable.from(jsonFile).map(new Func1<File, Observable<String>>() {
    @Override public Observable<String>> call(File file) {
        return new RxGson().toJson(new FileReader(file), Object.class);
    }
}); // you get Observable<Observable<String>> here

이 시점 subscribe()에서 그러한 관찰 가능한 것은 까다로울 것 입니다. 그것 안에 Observable<String>당신은 다시 subscribe()가치를 얻는 데 필요한 것을 얻을 것입니다. 실용적이지 않고보기에 좋지 않습니다.

따라서 유용한 한 가지 아이디어는이 관측 가능한 관측 가능 항목을 “평평하게”하는 것입니다 (이름이 _flat_Map 인 곳을 볼 수 있습니다). RxJava는 옵저버 블을 평탄화하는 몇 가지 방법을 제공하며 단순성을 위해 병합 이 원하는 것을 가정 할 수 있습니다 . 병합은 기본적으로 많은 관측 가능 항목을 가져 와서 방출 할 때마다 방출합니다. (많은 사람들은 스위치 가 더 나은 기본값 이라고 주장 할 것입니다. 그러나 하나의 값만 내 보내면 어쨌든 상관 없습니다.)

이전 스 니펫을 수정하면 다음과 같이됩니다.

Observable.from(jsonFile).map(new Func1<File, Observable<String>>() {
    @Override public Observable<String>> call(File file) {
        return new RxGson().toJson(new FileReader(file), Object.class);
    }
}).merge(); // you get Observable<String> here

구독 (또는 맵핑 또는 필터링 또는 …)을 구독하면 String값을 얻을 수 있으므로 훨씬 유용 합니다. (또한 merge()RxJava에는 이러한 변형이 존재하지 않지만 병합 개념을 이해하면 작동 방식을 이해하기를 바랍니다.)

따라서 기본적으로 merge()이것들은 아마도 map()관측 값 반환에 성공했을 때만 유용 하기 때문에 이것을 반복해서 입력 할 필요가 없으므로 flatMap()속기로 작성되었습니다. 매핑 함수를 일반적인 방식으로 적용 map()하지만 나중에 반환 된 값을 내보내는 대신 “평평하게”(또는 병합)합니다.

이것이 일반적인 사용 사례입니다. Rx를 어디에서나 사용하는 코드베이스에서 가장 유용하며 옵저버 블을 반환하는 많은 메서드가 있으며 옵저버 블을 반환하는 다른 메서드와 체인을 연결하려고합니다.

사용 된 경우에는 map()방출 된 하나의 값만에서 방출 된 onNext()다른 값으로 변환 할 수 있기 때문에 유용합니다 onNext(). 그러나 여러 값으로 변환 할 수 없으며 전혀 값이 없거나 오류가 없습니다. 그리고 akarnokd 가 그의 대답에 썼 듯이 (그리고 아마도 그는 일반적으로 나보다 훨씬 똑똑하지만 적어도 RxJava에 관해서는) 당신에게서 예외를 던져서는 안됩니다 map(). 그래서 그 대신 사용할 수있는 flatMap()및

return Observable.just(value);

모든 것이 잘되면

return Observable.error(exception);

무언가가 실패했을 때.
자세한 내용은 https://stackoverflow.com/a/30330772/1402641에 대한 답변을 참조하십시오.

답변

Observable<LoginResponse> login(String email, String password);

Observable<UserInfo> fetchUserInfo(String userId);

login(email, password)
        .flatMap(response ->
                fetchUserInfo(response.id))
        .subscribe(userInfo -> {
            // get user info and you update ui now
        });

Observable.from(jsonFile).flatMap(new Func1<File, Observable<String>>() {
    @Override public Observable<String> call(final File file) {
        try {
            String json = new Gson().toJson(new FileReader(file), Object.class);
            return Observable.just(json);
        } catch (FileNotFoundException ex) {
            return Observable.<String>error(ex);
        }
    }
});