[리액티브] map vs flatMap 와우..진짜.

 

 

map 구독이 안 되고

Flux.just("SMS", "EMAIL")
.map(it ->
             userRoleRepository.save(UserRole.builder().userUid(userUid).type("MARKETING")
                    .roleName(it).build())
).subscribeOn(Schedulers.boundedElastic()).subscribe();

 

 

flatMap은 구독이 된다.

Flux.just("SMS", "EMAIL")
.flatMap(it ->
             userRoleRepository.save(UserRole.builder().userUid(userUid).type("MARKETING")
                    .roleName(it).build())
).subscribeOn(Schedulers.boundedElastic()).subscribe();

 

 

구독이 되고 안 되고 진짜 중요한 문제다.ㅋㅋ 비지니스 로직이 수행이 안 되는 것이다 ( 커밋 X)

 

물론 아래 처럼 내부에서 구독을 조지면 되는데;;; 뭔가 잘 못 사용하고 있는 느낌이라....

Flux.just("SMS", "EMAIL")
.map(it ->
             userRoleRepository.save(UserRole.builder().userUid(userUid).type("MARKETING")
                    .roleName(it).build()).subscribe()
).subscribeOn(Schedulers.boundedElastic()).subscribe();

 

 

해당 이유를 알면 마스터 느낌인데.. 일단 난 모르겠다. ㅠ 일단 P@ss