본격적으로 Reactive Stream 에 대해 알아보겠다. (by java.util.concurrent.Flow) Publisher Reactive Stream 의 Publisher 이다. - publisher 는 데이터 혹은 이벤트(메시지)를 제공한다. subscribe - publisher 에 subscriber 를 등록할 수 있다. (다수를 등록할 수 도 있다.) Subscriber Reactive Stream 의 Subscriber 이다. Subscriber 는 Publisher 로 부터 다양한 이벤트가 들어오는 채널을 구현해야한다. 참고 publisher 에서 subscriber 에게 데이터 혹은 이벤트를 전달하는 방식은 push 방식이다. onSubscribe - publisher 에서 호출..

지난 포스팅(Reactive manifesto) 에 이어 작성한다. Reactive Programming (반응형 프로그래밍) 이란.. 비동기 이벤트 처리 및 데이터 스트림 개념을 기반으로 하는 선언적 프로그래밍 패러다임이다. 위의 정의를 대충 느끼지말고 정확하게 의미를 짚어서 이해를 해보자.. 그럼, 알아야할 개념을 한단계씩 알아가보겠다. 고차 함수 (High Order Function) 란.. 함수를 매개변수로 받거나 함수를 리턴하는 함수를 뜻한다. 일급 객체 (First Class Object) 란.. - 변수에 할당할 수 있어야한다. - 객체의 인자로 넘길수 있어야한다. - 객체의 리턴 값으로 리턴할 수 있어야한다. 참고 자바 8 이전에서는 함수가 일급 객체에 해당되지 않았지만.. 자바 8 이후 ..

이번 포스팅의 주제는 Reactive Manifesto - Published on September 16 2014. (v2.0) 이다. https://www.reactivemanifesto.org/ The Reactive Manifesto Responsive: The system responds in a timely manner if at all possible. Responsiveness is the cornerstone of usability and utility, but more than that, responsiveness means that problems may be detected quickly and dealt with effectively. Responsive systems www.rea..

Marble Diagram 이란.. projectreactor 의 Reactor 를 사용하면 자주 보이는 다이어그램이다. Marble Diagram 은 Mono 와 Flux 의 연산자 동작을 시각적으로 보여주기 위함이며, javadoc 전체에서 쉽게 볼 수 있을 것이다. Marble Diagram 읽는 법 위의 화살표는 시간의 흐름을 나타낸다. 왼쪽에서 오른쪽 방향으로 시간 순서이다. 위 다이어그램에서 도형은 파이프라인을 지나는 하나의 element 라 보면된다. 세로 선은 onComplete 이벤트를 뜻한다. C 다이어그램에서는 타임라인에 "X" 표시가 있는데 이는 onError 이벤트가 발생되었음을 나타낸다. D 다이어그램에서는 타임라인에 element 만 존재하고, 이벤트는 발생하지 않아서 종료 되..