caporatang

Hot, Cold Publisher Cold Publisher ? Reactive streams 예시 코드처럼 subscribe가 시작되는 순간 데이터를 생성해서 전송하는 케이스를 Cold Publisher라고 한다. Cold Publisher는 파일 읽기, 웹 API 요청 등 subscriber에 따라 독립적인 데이터 스트림을 제공한다. Hot Publisher ? subscriber가 없더라도 데이터를 생성하고 stream에 push하는 publisher이다. 트위터 게시글 읽기, 공유 리소스 변화 등 여러 subscriber에게 동일한 데이터를 전달한다. ColdPublisher 구현 public class SimpleColdPublisher implements Flow.Publisher{ // S..

Reactive streams Reactive 시스템을 구성하기 위해서는 Reactive Programming을 사용해야 하고 Reactive Programming을 가장 쉽게 구현할 수 있게 해주는게 Reactive streams다. Reactive stream의 구조 데이터 혹은 이벤트를 제공하는 Publisher 데이터 혹은 이벤트를 제공받는 Subscriber 데이터 흐름을 조절하는 Subscription Publisher는 Subscription을 Subscriber에게 전달하고, Subscription 내부에는 데이터를 얼마나 받고, 데이터를 그만 받을지를 설정할 수 있다. 이 Subscription으로 Subscriber는 Publisher에게 데이터를 더 요청하거나, 데이터를 그만 받겠다를..