반응형 RxKotlin39 RxJava, RxKotlin - takeUntil 함수 [출처 - RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에] 본 글은 'RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에' 를 학습하면서 정리한 글입니다 마블다이어그램 참고 - http://reactivex.io/RxJava/javadoc/io/reactivex/Flowable.html#takeUntil-org.reactivestreams.Publisher- takeUntil 함수는 take 함수에 조건을 설정합니다. 마블다이어그램을 보면서 설명하겠습니다. 마블다이어 그램을 보면 원을 발행중에 6각형이 들어오면 발행을 멈추는 것을 볼 수 있습니다. 즉 take 처럼 일정 개수를 발행하되 다른 Observable이 특정 값을 발행하면 발행을 중단하.. 2020. 1. 19. 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. 이전 1 2 3 4 5 6 7 ··· 10 다음 반응형
