글쓰는 개발자

Single 데이터를 1건만 통지하거나 에러를 통지한다. 데이터 통지 자체가 완료를 의미하기 때문에, 완료 통지는 하지 않는다. 데이터를 1건만 통지하므로, 데이터 개수를 요청할 필요가 없다. onNext(), onComplete()가 없으며 이 둘을 합한 onSuccess()를 제공한다. Single의 대표적인 소비자는 SingleObserver이다. 클라이언트 요청에 대응하는 서버의 응답이 Single을 사용하기 좋은 대표적인 예이다. Maybe 데이터를 1건만 통지하거나 1건도 통지하지 않고 완료 또는 에러를 통지한다. 데이터 통지 자체가 완료를 의미하기 때문에 완료 통지는 하지 않는다. 단, 데이터를 1건도 통지하지 않고 처리가 종료될 경우에는 완료 통지를 한다. Maybe의 대표적인 소비자는 M..

Flowable과 Observable의 비교 Flowable은 Reactive Streams의 인터페이스를 구현하고, Observable은 그렇지 않다. 아래의 Flowable는 Publisher를 구현하고 있다. /* Flowable.java */ public abstract class Flowable implements Publisher { ... } /* Publisher.java */ package org.reactivestreams; // reactive streams 패키지 public interface Publisher { public void subscribe(Subscriber

목차 Reactive Streams? Cold Publisher & Hot Publisher Cold Publisher & Hot Publisher 예제로 살펴보기 Reactive Streams? 리액티브 프로그래밍 라이브러리의 표준 사양(https://github.com/reactive-streams/reactive-streams-jvm) 리액티브 프로그래밍에 대한 인터페이스만을 제공함 RxJava는 Reactive Streams의 인터페이스들을 구현한 구현체이다. Reactive Streams는 다음 4개의 인터페이스를 제공 Publisher Subscriber Subscription Processor Publisher public interface Publisher { public void subs..

목차 Reactive Programming Reactive Programming 필수 요소 예제 Reactive Programming? In computing, reactive programming is a declarative programming paradigm concerned with data streams and the propagation of change. 컴퓨팅에서 반응형 프로그래밍은 데이터 스트림 및 변경 전파와 관련된 선언적 프로그래밍 패러다임입니다. 간단하게, Reactive Programming이란 데이터 변경 이벤트를 감지하여 stream으로 흘려보내는 행위를 선언적 프로그래밍 방식으로 사용하는 프로그래밍 패러다임이다. 선언적 프로그래밍 선언적 프로그래밍은 명령형 프로그래밍에 대조..