Notice
Recent Posts
Recent Comments
Link
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | 6 | 7 |
8 | 9 | 10 | 11 | 12 | 13 | 14 |
15 | 16 | 17 | 18 | 19 | 20 | 21 |
22 | 23 | 24 | 25 | 26 | 27 | 28 |
29 | 30 | 31 |
Tags
- 뷰 상태 저장
- compileKotlin FAILED
- 카드내역 공유
- nvidia-docker
- 뷰 상태복구
- Quickly
- kotlin
- moveToState
- 타이머앱
- List
- android clean architecture
- todofication
- Android
- 안드로이드 클린 아키텍쳐
- 대학톡
- 올인원타이머
- 특가게시판
- 카드 내역 공유 앱
- 안드로이드
- andorid
- RxJava
- 특가알람
- java.lang.OutOfMemoryError: Java heap space
- Koin
- recyclerview
- 작성
- 특가촌
- RX
- onViewCreated
- fragment
Archives
- Today
- Total
목록concatMapEager (1)
seoft
[Rx,Kotlin] list to stream 병렬처리 순차적 응답받기
concatMapEager는 기존 concatMap 역할에서 스트림이 병렬로 처리된다는 특징을 가지고 있다. 그렇기 때문에 동시성과 함께 순서가 보장되어야 될 경우 concatMapEager 연산자를 사용하면 된다. 여러 api host로부터 값을 받오는 즉시 처리하되, 순서를 보장해야되는게 요구사항이라고 가정을 해본다. request함수를 사전 정의 하였는데 각 url에 따른 randome 시간 후에 response가 오는 상황으로 가정하고 해당 함수를 거쳐 Single로 반환된다. url string 리스트를 개별 flowable로 반환하여 concatMapEager내에서 하나씩 태우게 되고 반환된 Single 결과값을 flowable으로 변환에 스트림을 진행한다. string리스트의 순서와 동일하게..
android
2020. 7. 13. 23:06