본문 바로가기
반응형

2023년 이전/ReativeX43

RxJava,RxKotlin - all 함수 [출처 - RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에] 본 글은 'RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에' 를 학습하면서 정리한 글입니다 마블다이어그램 참고 - http://reactivex.io/RxJava/javadoc/io/reactivex/Flowable.html#all-io.reactivex.functions.Predicate- all 함수는 주어진 조건에 100% 맞을 때만 true 값을 발행하고 조건이 맞지 않으면 false를 발행합니다. 마블다이어그램을 보면 모든 데이터가 원이기 때문에 true를 발행합니다. testCode를 보겠습니다.(CommonUtils와 CommonUtilsk의 내용은 여기에서 확인 할 수 .. 2020. 1. 19.
RxJava, RxKotlin - skipUntil 함수 [출처 - RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에] 본 글은 'RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에' 를 학습하면서 정리한 글입니다 마블다이어그램 참고 -http://reactivex.io/RxJava/javadoc/io/reactivex/Flowable.html#skipUntil-org.reactivestreams.Publisher- skipUntil 함수는 데이터 발행을 다른 Observable에서 특정 값이 들어오는 그 순간 부터 데이터를 발행합니다. 그럼 test code를 확인해 보겠습니다.( CommonUtils와 CommonUtilsk의 내용은 여기에서 확인 할 수 있습니다.) Java import io.reac.. 2020. 1. 19.
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.
반응형