반응형 RxJava37 RxJava, Rxkotlin 관련 CommonUtils와 CommonUtilsk RxJava, RxKotlin에서 사용중인 CommonUtils와 CommonUtilsk의 code는 다음과 같습니다. CommonUtils.java import java.util.Random; public class CommonUtils{ public static long startTime; public static void exampleStart(){ startTime = System.currentTimeMillis(); } public static void exampleComplete(){ startTime = System.currentTimeMillis(); } public static void sleep(int mills){ try{ Thread.sleep(mills); }catch (Inter.. 2020. 1. 19. RxJava, RxKotlin - amb 함수 [출처 - RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에] 본 글은 'RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에' 를 학습하면서 정리한 글입니다 마블다이어그램 참고 -http://reactivex.io/RxJava/javadoc/io/reactivex/Flowable.html#amb-java.lang.Iterable- amb는 ambiguous(모호한)의 줄임말 입니다. 여러 개의 Observable 중에 1개의 Observable을 선택하는데, 선택 기준은 가장 먼저 데이터를 발행한 Observable입니다. 이 후 나머지 데이터는 전부 무시합니다. 마블다이어 그램을 보면 이렇게 원이 먼저 들어왔기 때문에 원의 데이터만 발행하고 있습니.. 2020. 1. 19. RxJava, RxKotlin - Concat 함수 [출처 - RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에] 본 글은 'RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에' 를 학습하면서 정리한 글입니다 마블다이어그램 참고 - http://reactivex.io/RxJava/javadoc/io/reactivex/Flowable.html#concat-java.lang.Iterable- concat 함수는 두개 이상의 Observable을 이어주는 역할을 하는 함수 입니다. 첫 번쨰 Observable이 onComplete가 발생해야 두번째 observable을 구독합니다. 마블다이어그램을 보면 간단한 testCode를 보면 Java import io.reactivex.Observable; impo.. 2020. 1. 17. RxJava, RxKotlin - merge 함수 [출처 - RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에] 본 글은 'RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에' 를 학습하면서 정리한 글입니다 마블다이어그램 참고 - http://reactivex.io/RxJava/javadoc/io/reactivex/Flowable.html#merge-java.lang.Iterable- merge 함수는 Observable의 순서와 데이터와 상관없이 먼저 입력되는 데이터를 그대로 발행하는 함수 입니다. 한마디로 모든 데이터를 싹다 발행하는데, 만일 어느 Observable이 종료 또는 error가 날 경우 멈춥니다. 간단한 test Code를 보겠습니다. Java import io.reactivex... 2020. 1. 17. 이전 1 2 3 4 5 6 7 ··· 10 다음 반응형
