Tech.io의 'Reactive Programming with Reactor 3'을 공부하면서 정리하는 글입니다. 리액터는 에러를 전파하고 복구할 수 있는 여러 연산(=operators)을 가지고 있습니다. 복구는 보통 순서 변경 및 새로운 Subscription구독 과 같은 방법이 있습니다. 문제풀이 에러 발생시 Mono 형태의 기본값을 리턴하는 예 //======================================================================================== // TODO Return a Mono containing User.SAUL when an error occurs in the input Mono, else do not change the in..
Tech.io의 'Reactive Programming with Reactor 3'을 공부하면서 정리하는 글입니다. 위 다이어그램 중 볼륨 컨트롤은 리액티브 스트림의 Backpressure를 의미합니다. Backpressure는 Subscriber가 Publisher에게 얼마만큼의 데이터를 처리할지 신호를 보내며, 이와 같은 방법으로 Publisher의 데이터 생산을 제한합니다. 해당 컨트롤은 Subscription 레벨에서 처리됩니다. 구독(=subscribe())는 Subscription 객체를 반환합니다. 그리고 해당 객체의 request(long)또는 cancel()을 이용해서 데이터의 흐름을 제어하게 됩니다. 특히, request(Long.MAX_VALUE)은, 무제한 데이터 요청을 의미하며, ..
Tech.io의 'Reactive Programming with Reactor 3'을 공부하면서 정리하는 글입니다. 시퀀스 병합은 여러 Publisher로 부터 값을 구독하여 하나의 Flux로 데이터를 전달하는 것을 의미한다. 문제풀이 // TODO Merge flux1 and flux2 values with interleave Flux mergeFluxWithInterleave(Flux flux1, Flux flux2) { return Flux.merge(flux1, flux2); } Flux.merge: Publisher 의 순서와 상관없이 데이터 발생할 때마다 바로바로 Flux로 전달. // TODO Merge flux1 and flux2 values with no interleave (flux1 ..
- Total
- Today
- Yesterday
- Node.js
- reactiveprogramming
- unit test
- Git
- gvim
- Coffeescript
- 윈도우즈
- Commonjs
- React
- 자바스크립트
- tipoftheday
- VIM
- 자바
- REACTOR
- intellij
- console
- Eclipse
- Configuration
- dojo
- 빔
- 리액터
- 스프링인액션
- VI
- JavaScript
- Windows
- Java
- maven
- 커피스크립트
- 리액티브프로그래밍
- Widget
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | 6 | |
7 | 8 | 9 | 10 | 11 | 12 | 13 |
14 | 15 | 16 | 17 | 18 | 19 | 20 |
21 | 22 | 23 | 24 | 25 | 26 | 27 |
28 | 29 | 30 | 31 |