본문으로 바로가기

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




1
2
3
4
5
6
7
8
Flowable<Map<StringString>> source = tradingService.request(tradingRequest)
     .map(jsend -> (Map<String, Object>) jsend.data)
     .map(data -> (ArrayList<Map<StringString>>) data.get("items"))
     .flatMap(dataArl -> Flowable.fromIterable(dataArl));
 
source.subscribe(item -> {
     System.out.println(item);
});
cs

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



'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

댓글을 달아 주세요