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

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로 나온다.