본문 바로가기

IT/RxJava, RxAndroid, RxKotlin

[RxJava] flowable Flowable과 Observable의 차이? 공식문서에서는 해당링크의 상황에서 맞춰 Observable과 Flowable을 구분해서 사용하라고 합니다.여기서 가장 중점적으로 봐야할것은 데이터의 처리 갯수 뿐아니라 데이터의 발행속도가 구독자가 처리하는 속도보다 현저하게 빠른경우즉 공급이 수요보다 현저히 빠른경우 OOME(out of memory Exeception) 과 같은 에러가 발생할 수 있는데 BackPreesure라는 배압에 대한 이슈를 Buffer를 이용하여 대응하는 기능을 제공합니다. 해당 내용은 아래의 링크를 통해 확인가능합니다. * 어떻게 나눠서 사용해야할까? https://github.com/ReactiveX/RxJava/wiki/What's-different-in-2.0#which-ty..
[RxJava,RxKotlin] RxJava , Observable 알아보기 안녕하세요 남갯입니다 개인적으로 RxJava,RxKotlin 에 대해 정리해보려고합니다. ReactiveX란 ?ReactiveX 는 비동기 프로그래밍 그리고 Observable 시퀀스를 이용해 이벤트를 처리하기위한 라이브러리입니다.즉 위 말을 간단하게 말해보면 비동기적 데이터흐름을 처리하는 프로그래밍입니다. Rxjava는 2013년 2월 넷플리스 기술블로그에서 처음 소개되었고 REST기반의 서비스를 개선하고자 프로젝트를 진행했고 .net환경의 rx를 JVM에 포팅하여 만들어지게 되었습니다. Observable이란? ReactiveX는 옵저버패턴을 사용하기 때문에 rx의 Observer는 Observable을 구독하게 됩니다. Observable이 emit하는 하나 혹은 연속된 item 에 대해 Obser..
[RxJava, RxKotlin,RxAndroid] concat , merge, zip 알아보기 안녕하세요 남갯입니다 오늘은 concat 과 merge 와 zip를 알아보도록 하겠습니다. -concat concat은 두개의 Observable을 합쳐 첫번째 Observable을 발행 한 뒤 두번째 Observable을 발행합니다. 위쪽의 Timestamp와 아래쪽의 Timestamp는 동일한 시기에 각각 데이터를 발행했지만 concat 이후에 보면 위쪽 데이터 이후에 아래쪽 데이터가 발행되는것을 볼 수 있습니다. 즉 요즘은 해당 api를 부르기위해 auth를 요청받는 api가 있는데, 그때 이용하게 되면 좋을것 같습니다. 해당 세션이 유효한지 판단 한 후원하는 api를 요청할 때 이용하면 좋을것 같습니다. val test1 = Observable.just("1", "2", "3").delay(2, ..