RxJava

오늘부터 RxJava에 대하여 블로그에 기록을 해볼 생각입니다. 제가 RxJava를 배우려는 이유는 안드로이드 채용 공고를 보면 RxJava를 사용할 수 있는 사람을 찾고 있는 회사들이 있어서 자격요건을 채우기 위해 배우고 나의 프로젝트에 적용해볼 까 합니다.Rx란 무

인자로 넣은 데이터를 차례로 발행하려고 Observable을 생성합니다. 특정 값이나 미리 정의된 값 집합을 발행하는 Observable을 생성하는 데 주로 사용된다.백문이 불여일타 보는 거 보다는 직접 코드를 쳐보시면 이해가 가실 겁니다😃단일 항목을 발행하는 Obs

Range는 이름 그대로 특정 범위의 연속된 정수를 발행하는 옵저버블(observable)을 생성하는 유틸리티 함수입니다.이 함수는 비동기 작업에서 특정 횟수만큼 반복하거나, 정수 범위를 나타내는 등의 상황에서 사용이 됩니다.사용법은 간단해요 range 함수안에 시작할

특정 항목이나 연속된 항목들을 반복적으로 배출하는 Observable을 생성한다 이 함수는 반복적인 작업을 처리할 때 유용하다.사용법은 observable.repeat(n) repeat 함수 안에 n번 만큼 반복할 숫자를 넣어주면 됩니다.

특정 시간별로 연속된 정수형을 배출하는 Observable을 생성하는 연산자이다. 이 연산자는 주기적인 작업이나 타이머 기능을 구현하는 데 유용합니다. 즉 주기적으로 데이터를 가져오거나 타이머 이벤트를 처리하거나, 일정한 간격으로 작업을 수행하는 등을 구현할 수 있어요

공식 문서에 따르면 지정된 시간이 지나고 난 후 항목을 하나 배출하는 Observable을 생성한다고 설명이 되어있습니다. 주로 주어진 시간이 지나고 값을 발행하는 일회성 작업이나 지연 실행이 필요한 경우에 사용이 된다.Timer 연산자는 Long 타입의 delay 파

공식 문서에 따르면 직접적인 코드 구현을 통해 옵저버 메서드를 호출하여 Observable을 생성한다 라고 기록이 되어 있다. 쉽게 생각하면 Observable을 제어하고 사용자가 원하는 동작을 정의 할 수 있는 연산자이다. 주의해야 할 점은 Observable을 동작

이름 그대로 특정 조건을 만족하는 항목들만 배출한다. 특정 조건을 만족하는 값을 필터링 하거나 불필요한 값을 거르고 싶을 때 사용하면 유용하게 쓸 수 있습니다.Filter 내부를 들여다 보면 다음과 같이 구현이 되어있는데 filter 메소드는 @NonNull Predi

Observable에서 발행된 마지막 항목을 발행한다. Last 연산자는 Observable이 최소한 한 개 이상의 항목을 발행하는 것이 보장될 때 사용하는 것이 좋다. 이 예제는 newJeansList에서 마지막 요소를 보여주는 예제입니다. 코드를 살펴보면 newJe

Distinct는 Observable이 배출하는 항목들 중 중복을 제거한 항목들을 배출한다.사용법은 먼저 Observable에서 just 함수를 사용해 차례대로 방출하도록 하고 distinct() 연산자를 사용하여 중복된 아이템을 제거합니다.결과를 구독합니다. 각 아이

Observable에서 발행되는 항목의 일부를 건너뛰는 데 사용됩니다 skip은 Observable이 배출한 처음 n개의 항목들을 숨기고 skipLast는 Observable이 배출한 마지막 n개의 항목들을 숨긴다사용법은 간단하다. skip, skipLast를 사용해

Observable로부터 정기적으로 항목들을 수집하고 묶음으로 만든 후에 묶음 안에 있는 항목들을 한번에 하나씩 배출하지 않고 수집된 묶음 단위로 배출한다. 이를 통해 데이터를 일정한 크기의 그룹으로 나누거나, 일정 시간 간격으로 데이터를 모아서 처리할 수 있다.bu

Observable이 배출한 항목에 함수를 적용한다 1부터 5까지의 숫자를 발행하고, map을 사용하여 각 숫자를 2배로 변환하는 예제입니다.246810

하나의 Observable이 발행하는 항목들을 여러개의 Observable로 변환하고, 항목들의 배출을 차례차례 줄 세워 하나의 Observable로 전달한다. FlatMap연산자를 사용하면 스트림의 각 항목을 비동기적으로 처리하고, 각 변환 결과를 결합하여 새로운 옵

원본 Observable이 배출하는 항목들을 키(Key) 별로 묶은 후 Observable에 담는다. 이렇게 키 별로 만들어진 Observable들은 자기가 담고 있는 묶음의 항목들을 배출한다.GroupBy를 사용해 뉴진스에서 19세 이상인 멤버들만 묶어 보도록 하겠습

Merge 연산자는 여러 개의 옵저버블(Observable)을 하나의 옵저버블로 결합하는 연산자입니다.수집된 항목들은 동시에 발행되며, 병합된 스트림에서는 항목들의 순서가 보장되지 않습니다.뉴진스 리스트를 하나 더 만들어 합쳐보겠습니다.merge(),merge2()는

두 개 이상의 Observable들이 항목을 발행할 때 Observable 순서대로 배출하는 항목들을 하나의 Observable 배출로 연이어 배출한다. concat 연산자는 옵저버블들을 순차적으로 처리하고 싶을 때 유용하게 사용될 수 있습니다.Observable 2개

StartWith는 Observable의 시퀸스를 다른 Observable 또는 데이터로 시작할때 사용된다. 즉,Observable에서 항목을 방출하기 전에 지정된 항목 시퀀스를 방출한다.사용법은 startWith연산자에 item1, item2과 같이 Observabl

두 개 이상의 Observable을 조합하여 새로운 옵저버블을 생성하는 연산자입니다. zip 연산자는 각 옵저버블에서 발행된 항목을 조합하여 튜플 또는 결과 항목으로 발행한다.zip 함수에는 Observable.zip()을 사용하기 위해 num, char의 Observ