에러 처리 에러가 발생하면 어떻게 처리하라 라고 명시할 수 있다. public class Part07Errors { Mono betterCallSaulForBogusMono(Mono mono) { return mono.onErrorResume(error->Mono.just(User.SAUL)); } Flux betterCallSaulAndJesseForBogusFlux(Flux flux) { return flux.onErrorResume(error->Flux.just(User.SAUL, User.JESSE)); } Flux capitalizeMany(Flux flux) { return flux.map(user->{ try{ return capitalizeUser(user); }catch(GetOutOfH..

Backpressure ( = Request, Pull ) Volume control Subscriber 가 처리할 수 있는 수준의 양을 받도록 Stream 의 양을 조절하는 개념 Subscriber 가 publisher 에게하는 피드백 메카니즘 이다. 얼마나 데이터를 처리하길 원하는지 publisher 에게 이야기하는 것 Subscription level 에서 처리된다. publisher.subscribe 할 때 subscription 을 줄 수 있다. publisher.subscribe 에 의해 onSubscribe 가 실행된다. onSubscribe 에의해 전달받은 subscription 이 사용한다. Backpressure ( = Request, Pull ) 의 크기를 보는 방법 : log Flu..

StepVerifier react-test 의 StepVerifier 으로 publisher 의 동작을 확인할 수 있다. 기대하던 이벤트와 일치하지 않는 이벤트가 발생하면 에러를 발생시킨다. 반드시 verify 라는 메소드를 호출해야한다. verify 를 해야 subscribe 가 시작된다. public class Part03StepVerifier { void expectFooBarComplete(Flux flux) { StepVerifier.create(flux) .expectNext("foo") .expectNext("bar") .verifyComplete(); } void expectFooBarError(Flux flux) { StepVerifier.create(flux) .expectNext("f..

강의 참조 : https://www.youtube.com/watch?v=VeSHa_Xsd2U&list=PLfI752FpVCS9hh_FE8uDuRVgPPnAivZTY 문서 참조 : https://tech.io/playgrounds/929/reactive-programming-with-reactor-3/Intro Introduction to Reactive Programming - Reactive Programming with Reactor 3 Explore this playground and try new concepts right into your browser tech.io Reactor : JVM 기반의 Reactive Stream 을 구현한 라이브러리 Reative programming 선언적인 코..