데이터 필터링 연산자 filter 전달 받은 데이터가 조건에 맞는지 확인한 후, 결과가 true인 데이터만 통지한다. filter 라는 단어의 사전적 의미가 무언가를 걸러낸다는 의미이다. 파라미터로 받는 Predicate 함수형 인터페이스에서 조건을 확인한다. public class ObservableFilterExample01...

RxJava의 연산자(Operator)란? RxJava에서의 연산자는 메서드(함수)다. 연산자를 이용하여 데이터를 생성하고 통지하는 Flowable이나 Observable 등의 생산자를 생성할 수 있다. Flowable이나 Observable에서 통지한 데이터를 다양한 연산자를 사용하여 가공 처리하여 결과값을 만들어 낸다. 연산자의 ...

메서드 레퍼런스란? 우리말로 번역하면 메서드 참조라는 의미이다. 람다 표현식 body(몸체) 부분에 기술되는 메서드를 이용해서 표현되며, 메서드의 이름만 전달한다. 구분자(::)를 붙이는 방식으로 메서드 레퍼런스를 표현한다. 메서드 레퍼런스를 사용하면 람다 표현식이 더욱 간결해진다. 메서드 레퍼런스의 표현 예 ...

함수형 인터페이스란? 함수형 인터페이스는 말 그대로 Java의 interface 이다. 함수형 인터페이스는 단 하나의 추상 메서드만 가지고 있는 인터페이스이다.(예외 : 디폴트 메서드는 포함할 수 있음) 함수형 인터페이스의 메서드를 람다 표현식으로 작성해서 다른 메서드의 파라미터로 전달할 수 있다. 즉, 람다 표현식 전체를 해당 함수...

Single 데이터를 1건만 통지하거나 에러를 통지한다. 데이터 통지 자체가 완료를 의미하기 때문에 완료 통지는 하지 않는다. 데이터를 1건만 통지하므로 데이터 개수를 요청할 필요가 없다. onNext(), onComplete()가 없으며 이 둘을 합한 onSuccess()를 제공한다. Single의 대표적인 소비자는 Single...

Flowable과 Observable의 비교 Flowable Observable Reactive Streams 인터페이스를 구현함 Reactive Streams 인터페이스를 구현하지 않음 Subscriber에서 데이터를 처리한다. ...

Reactive Streams란? 리액티브 프로그래밍 라이브러리의 표준 사양이다. => 참고링크 리액티브 프로그래밍에 대한 인터페이스만 제공한다. RxJava는 이 Reactive Streams의 인터페이스들을 구현한 구현체이다. Reactive Streams는 Publisher, Subscriber, Subscription, ...

RxJava 프로젝트 환경 구축 순서 JDK 설치 (1.8 이상의 JDK가 설치 되어 있다고 가정함) IDE 다운로드 및 설치 IDE에 프로젝트 생 RxJava를 위한 의존 라이브러리 설치 정상적으로 동작하는지 Hello RxJava 코드 작성 및 실행 IDE 다운로드 및 설치 JetBrain의 IntelliJ IDE...

마블 다이어그램이란? 리액티브 프로그래밍을 통해 발생하는 비동기적인 데이터의 흐름을 시간의 흐름에 따라 시각적으로 표시한 다이어그램 마블 다이어그램을 알아야하는 이유 문장으로 적혀 있는 리액티브 연산자(Operators)의 기능을 이해하기 어려움 리액티브 연산자의 기능이 시각화 되어 있어서 이해하기 쉬움 리액티브 프로그래밍의 핵심인 연산...

리액티브 프로그래밍(Reactive Programming) 이란? 변화의 전파와 데이터 흐름과 관련된 선언적 프로그래밍 패러다임이다. 변화의 전파와 데이터 흐름 : 데이터가 변경 될 때 마다 이벤트를 발생시켜서 데이터를 계속적으로 전달한다. 선언적 프로그래밍 : 실행할 동작을 구체적으로 명시하는 명령형 프로그램이과 달리 선언형 프로그래밍은...