RxJava에 대해 알아보자 - 제3편 데이터 형변환 해서 Flowable로 만들기(flatmap)

728x90

RxJava에 대해 알아보자 - 제3편 데이터 형변환 해서 Flowable로 만들기

Flowable<Map<String, String>> source = tradingService.request(tradingRequest)
     .map(jsend -> (Map<String, Object>) jsend.data)
     .map(data -> (ArrayList<Map<String, String>>) data.get("items"))
     .flatMap(dataArl -> Flowable.fromIterable(dataArl));
 
source.subscribe(item -> {
     System.out.println(item);
});

.flatMap()은 map한 결과가 Observable 또는 Flowable등 able로 나온다.

728x90

저작자표시비영리

'Language > JAVA' 카테고리의 다른 글

java do while  (0)	2018.05.02
java 재귀 호출, 재귀 함수  (0)	2018.04.05
RxJava에 대해 알아보자 - 제3편 데이터 형변환 해서 Flowable로 만들기(flatmap)  (0)	2018.04.04
JSend란?  (0)	2018.04.04
Pair.of at Apache commons 사용법  (0)	2018.03.27
maven test없이 실행  (0)	2018.03.15