RxJava 7

RxJava - subscribeOn, observeOn 를 제대로 쓰고 있는걸까?

해당 글은 https://vagabond95.me/posts/is-this-rxjava-1/ [안드로이드] 그런 Rx Java 로 괜찮은가 1 - subscribeOn, observeOn - 기록은 기억을 지배한다 구글은 점점 더 안드로이드 아키텍처를 리엑티브하게 구조화 하려는 움직임을 보이고 있고, Databinding, LiveData 그리고 RxJava 는 그러한 구조화 작업의 핵심 토대를 담당하고 있다. 또한 주력으로 vagabond95.me 을 읽고 깊게 Rx에 대해 고민하지 않았던 스스로를 반성하는 포스팅임을 밝힙니다. ㅜㅜ rx 를 사용하다보면 subscribeOn, observeOn 를 자연스럽게 만나게 된다. 나도 개인 프로젝트에 rx와 retrofit 을 연동해서 값을 받아오고 그 값을..

RxJava - Hot Observable , Cold Observable

이전에 쓴 글(아래 링크 참고) 에서 뒷쪽에 https://choi-dev.tistory.com/107?category=972011 RxJava - Observable을 제외한 다른 생산자들 전 포스팅에서는 Observable에 대해서 알아봤다. 기본적인 생산자였는데 Observable 0개에서 n개의 데이터를 전달하는 생산자다. 기본적인 생산자로 단건(0 or 1)이 아니면 대부분 Observable을 쓴다. observe choi-dev.tistory.com Subject 에 대한 이야기가 나온다. 그때는 간단하게 설명하고 지나갔는데 공부하던중 추가로 알게 된 내용이 있어서 포스팅한다. 먼저 이 이야기를 시작하려면 제목의 Hot Observable , Cold Observable 에 대해서 알고 넘어..

RxJava를 Event Bus 처럼 쓰기

Event Bus 라는 라이브러리는 버스 네트워크의 동작 방식과 유사하게 하나의 이벤트를 동일 채널에 연결된 모든 노드들에게 보내는 역할을 해주는 라이브러리다. 안드로이드에서는 특정 동작을 했을때 intent 하거나 fragment 와 activity 사이의 데이터 전달을 할때 bundle이나 콜백 등 이런 동작들을 할 때가 있는데 이런 동작들은 코드의 재사용성을 줄이고 코드를 복잡하게 만들어서 깔끔하지 못한 코드가 될 수 있다. 이럴때 결합도를 낮추고 UI 끼리 데이터 통신을 더 편하게 처리하는게 이벤트 버스의 개념이다. 나는 interface 를 만들어서 콜백처리하는게 코드가 증가하고 불편해서 이 개념을 빌려다 쓸때가 많다. Rxjava로 이러한 동작을 어떻게 하게 할 수 있을까? 아래 코드처럼 Rx..

RxJava - Observable과 Observer 의 차이

둘다 자주 나오지만 이름도 비슷한게 정확한 차이점에 대해 궁금해졌다. 그래서 여기저기 찾아다니며 알아봤는데 차이점은 아래와 같다. Observable은 int, String 등등 여러 형태의 데이터를 관찰할 수 있는 즉 Observer 가 사용할 수 있는 형태로 바꾸는 역할을 한다. Observer 는 Observable 로 만들어진 데이터를 전달받고 그 데이터로 특정 행동을 취하는 역할을 한다. 아래 그림을 보면 더 이해하기 편하다. Observable observable = Observable .just("test1", "test2") .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()); observable.subscrib..

RxJava - Observable을 제외한 다른 생산자들

전 포스팅에서는 Observable에 대해서 알아봤다. 기본적인 생산자였는데 Observable 0개에서 n개의 데이터를 전달하는 생산자다. 기본적인 생산자로 단건(0 or 1)이 아니면 대부분 Observable을 쓴다. observer 방식으로 consumer 등록시 Observer를 구현해 전달한다. consumer 방식을 사용할 시 onNext, onComplete, onError와 onSubscribe가 있다. val observer = Observable.just(11, 12, 13) .map { if (it == 12) throw IllegalStateException() // 12에 에러 else it } observer.subscribe( { println("onNext $it") }, ..

RxJava - 시작하기

//RxJava implementation 'io.reactivex.rxjava3:rxandroid:3.0.0' implementation 'io.reactivex.rxjava3:rxjava:3.0.7' 안드로이드 기준으로 설명하겠다. 직접 공부하고 쳐보면서 포스팅 하고 있어서 Java와 Kotlin 예시가 같이 나오는건 양해해주시길 바란다. 언어만 다를뿐 사용법 자체에는 차이가 없다. Rxjava 라이브러리를 사용하기 위해 build.gradle 에 위의 내용을 입력하자. 일단 시작하기에 앞서 RxJava에서 기본적으로 이해 해야하는것들에 대해 먼저 알아보자. 1. Observable 2. Subscriber Observable 은 데이터 스트림을 만드는 요소. Subscriber 은 데이터 스트림을 ..

RxJava , RxKotiln 이란?

Rx는 뭔가? 바로 말하자면 Reactive Programming 이다. 반응형 프로그래밍이다. 반응형 프로그래밍이라는 단어가 왜 나오게 됐을까 기존 프로그램은 한번 변화가 있고나서 그것을 다시 알려주려고 부가적인 처리를 해줘야했다. 간단한 동작임에도 여러가지 처리를 해줘야해서 개발자 입장에서 피곤한 점도 많고 예상치 못한 문제가 발생할 위험도 존재했다. 이를 해결하기 위해 나온 프로그래밍 방식이 반응형 프로그래밍인데 프로그램이 자신의 주변과 끊임없이 상호작용하며 프로그램 자체가 주도해서 값이 변화하는것이 아닌 환경에 의해 변하면 이벤트를 받아 반응하는 프로그램을 의미한다. 당장은 와닿지 않을 수 있지만 이 Rx 관련 포스팅을 읽다보면 감이 올거라고 생각한다. 한마디로 즉, 근래에 떠오르고 있는 Reac..