본문 바로가기
반응형

RxJava37

RxJava,RxKotlin - 기타 함수 RxJava , RxKotlin에는 다양한 함수들이 존재합니다. 네트워크 라이브러리인 네티와 연동하는 RxNetty(https://github.com/ReactiveX/RxNetty) 아파치 http 모듈과 연동하는 RxAparcheHttp 등이 있고 (https://github.com/ReactiveX/RxApacheHttp) 수학 함수들을 모은 RxJavaMath가 있습니다. (https://github.com/ReactiveX/RxJavaMath) 근데 RxJavaMath는 RxJava 2.x를 지원하지 않으므로 RxJavaExtensions 라이브러리를 사용합니다. (https://github.com/akarnokd/RxJavaExtensions 현재 최신 버전은 compile "com.githu.. 2020. 1. 19.
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.
반응형