Reactive Programming

Reactive Programming

정의

Reactive programming is programming with asynchronous data streams.
You can listen to that stream and react accordingly

• Reactive Programming에서는 데이터의 모든 것을 스트림(Stream)으로 본다. 데이터 처리 스트림을 비동기적으로 처리하는 프로그래밍 리액티브 프로그래밍이라고 한다 (Reactive Programming)
• Observable (observer 할수 있는 객체 Observable), Observer (Observable에 subscribe 하는 객체)
• Subscriber에서는 `onNext` `onCompleted` `onError` 를 구현하는 Observer를 등록할수 있다.
• 여러가지 operator가 존재를 한다. (map, filter, throttle) 또한 backpressure 기능도 제공을 한다.
• Reactive Programming의 여러가지 구현체중 자주 사용하는 것은 ReactiveX이다.

ReactiveX - RxJava

Hello World Example

package rxjava.examples;

import io.reactivex.*;

public class HelloWorld {

    public static void main(String[] args) {

        Flowable.just("Hello world").subscribe(System.out::println);

    }

}

Reference

http://sculove.github.io/blog/2016/06/22/Reactive-Programming/

https://github.com/ReactiveX/RxJava