나만을 위한 블로그

이번 포스팅에선 변환 연산자 중 map, flatMap, groupBy에 대해 알아본다. map ReactiveX 공식 홈페이지에선 map 연산자를 아래와 같이 설명하고 있다. http://reactivex.io/documentation/operators/map.html ReactiveX - Map operator RxJS implements this operator as map or select (the two are synonymous). In addition to the transforming function, you may pass this operator an optional second parameter that will become the “this” context in which the t..

※ 이 포스팅에서 사용하는 Rxjava 버전은 3.x이다. 2.x를 사용할 경우 import 과정에서 오류가 날 수 있는데 2.x 버전에서 사용할 수 있도록 import 구문을 바꿔주기만 하면 문제없이 작동한다. 예전에 Rxjava의 생성 연산자 중 create, interval, just에 대해 포스팅했던 적이 있다. https://onlyfor-me-blog.tistory.com/329 [Rxjava] 연산자의 종류와 생성 연산자(create, interval, just) Rxjava에는 수많은 연산자들이 있다. http://reactivex.io/documentation/operators.html ReactiveX - Operators Introduction Each language-specific..

Rxjava는 데이터를 발행하는 생산자, 발행된 데이터를 받아 처리하는 소비자로 나눠진 형태로 구성된 Reactive Streams를 바탕으로 하는 라이브러리다. 또한 옵저버 패턴을 확장해서 관찰 대상 객체의 상태가 변하면 이걸 관찰하는 객체에 알려주는데, 결국은 누가 누군가를 구독해야 한다. 그럼 구독 해제는 어떻게 할까? 관심없어지면 당연히 구독 해제도 할 수 있어야 하는데 이걸 위해선 어떤 걸 사용하면 좋을까? 이걸 도와주는 것이 Disposable이다. 그 전에 왜 Disposable이란 이름이 붙었을까? 이 단어의 사전적 정의는 아래와 같다. 사용 후 버리게 되어 있는, 일회용의 / 이용 가능한 이 Disposable에 대한 설명을 찾아봤는데 공식 홈페이지로 보이는 Rxjava Javadoc에서..

제목의 3가지는 모두 Observable의 변형이다. 즉, Observer가 데이터를 처리할 수 있도록 데이터를 내보내는 역할을 하는 생성기라는 것이다. Observable을 아직 모른다면 예전에 작성한 포스팅이 있으니 참고하고 먼저 보고 오는 걸 추천한다. https://onlyfor-me-blog.tistory.com/326 [Rxjava] Observable이란? - 1 - 이제 코틀린과 같이 Rxjava를 공부할 건데, 어디서부터 공부할지가 막막해서 구글을 돌아다니다가 발견한 아래와 같은 순서로 한번 시도해보려고 한다. https://zzandoli.tistory.com/24 [RxJava] RxJava 학습 onlyfor-me-blog.tistory.com Observable과 Single은 R..

Rxjava에는 2가지 타입이 있다. 이전에 포스팅한 Observable과 새로 소개할 Flowable이 그것이다. 그러니 2가지를 비교하기 전에 먼저 Flowable이 무엇인지 확인해보자. Flowable을 사전에 치면 아래의 뜻이 나온다. Flowable : 유동적임 그런데 잘 보면 Flowable은 flow 뒤에 can을 의미하는 able이 붙은 형태다. 즉, flow란 단어가 원형인 단어다. 이 flow의 사전적 정의는 아래와 같다. Flow : 흐름 / 계속적인 공급(생산), (공급생산품의) 흐름, 이동 / 흐르다 흐름의 사전적 정의를 통해 생각해보면, flow란 한 자리에 멈춰 있는 게 아니라 어떤 방향을 향해 한 줄기로 잇따라 진행되는 것을 말하는 단어라는 걸 알 수 있다. 그럼 이젠 다른 ..

Rxjava에는 수많은 연산자들이 있다. http://reactivex.io/documentation/operators.html ReactiveX - Operators Introduction Each language-specific implementation of ReactiveX implements a set of operators. Although there is much overlap between implementations, there are also some operators that are only implemented in certain implementations. Also, each implementa reactivex.io 공식 홈페이지에 나와 있는 연산자들만 세봐도 양이 많은 걸 알..

이전 포스팅에서 Observable에 대해 살펴봤으니 이 포스팅에선 관련된 예제를 확인한다 먼저 Cold Observable의 예제다. import io.reactivex.rxjava3.core.Observable; import java.util.concurrent.TimeUnit; public class Main { public static void main(String[] args) { coldObservableText(); } public static void coldObservableText() { Observable observable = Observable.interval(1, TimeUnit.SECONDS); observable.subscribe(item -> System.out.printl..

이제 코틀린과 같이 Rxjava를 공부할 건데, 어디서부터 공부할지가 막막해서 구글을 돌아다니다가 발견한 아래와 같은 순서로 한번 시도해보려고 한다. https://zzandoli.tistory.com/24 [RxJava] RxJava 학습 순서 RxJava의 javadoc 문서를 보아도 글로 된 함수의 설명만으로는 이 함수가 무슨 동작을 하는지 이해하기 어렵다. 지금 공부하는 책에서 학습 순서를 제시하고 있는데 아래와 같이 학습 순서를 따라가 zzandoli.tistory.com Observable 클래스 이해하기(특히 Hot Observable, Cold Observable 개념 이해) map(), filter(), reduce(), flatMap()의 사용법 이해 (예제 분석 필요) 생성 연산자, ..

22.11.16) 최신 버전 수정 굳이 안드로이드 스튜디오 뿐 아니라 인텔리제이에서도 Rxjava를 사용할 수 있다. 이번 포스팅에선 인텔리제이에서 Rxjava를 사용할 수 있도록 환경설정하는 방법에 대해 포스팅하려 한다. 먼저 프로젝트를 하나 새로 만들자. 이렇게 선택해서 프로젝트를 만들어주자. 다음으로 프로젝트의 제목을 정하고 FINISH 버튼을 눌러주면 프로젝트 생성은 끝난다. 잠시 기다리면 인텔리제이 화면에 아래와 같은 코드들이 나올 것이다. plugins { id 'java' } group 'org.example' version '1.0-SNAPSHOT' repositories { mavenCentral() } dependencies { testImplementation 'org.junit.ju..

안드로이드에서 반응형 프로그래밍을 하기 위한 방법으로 Rxjava가 있다고 이전에 포스팅한 적이 있다. onlyfor-me-blog.tistory.com/286 [Android] Rxjava란? 안드로이드 디벨로퍼 홈페이지나 예제를 찾다보면 rxjava라는 키워드를 한번쯤은 보게 된다. rxjava는 뭘까? 그리고 왜 쓰는 걸까? 먼저 rxjava가 뭔지부터 찾아봤다. github.com/ReactiveX/RxJava ReactiveX/RxJa. onlyfor-me-blog.tistory.com 나중에 반응형 프로그래밍을 하게 될 일이 생길 수도 있기 때문에 따로 Rxjava 카테고리를 만들어서 따로 기록하려고 한다. 구구단 예제를 찾아서 빌드해보고 코드를 분석해봤는데 전혀 이해가 안 됐기 때문이 가장 ..