Memorization

20220704 TIL

코드파고 2022. 7. 5. 00:36

지금은 WebClient + Reactive 공부중...

Mono

0-1개의 결과만을 처리하기 위한 Reactor의 객체

Flux

0-N개인 여러 개의 결과를 처리하는 객체

Mono, Flux 둘 다 Reactive Stream의 Publisher Interface를 구현하고 있으며, Reactor 에서 제공하는 연산자의 조합을 통해 스트림을 표현한다

 

Reactor를 공부하기 위해

https://tech.io/playgrounds/929/reactive-programming-with-reactor-3/Mono

해당 예제를 통해 공부하고 있다

// TODO Return an empty Mono
	Mono<String> emptyMono() {
		return Mono.empty();
	}

//========================================================================================

	// TODO Return a Mono that never emits any signal
	Mono<String> monoWithNoSignal() {
		return Mono.never();
	}

//========================================================================================

	// TODO Return a Mono that contains a "foo" value
	Mono<String> fooMono() {
		return Mono.just("foo");
	}

//========================================================================================

	// TODO Create a Mono that emits an IllegalStateException
	Mono<String> errorMono() {
		return Mono.error(new IllegalStateException());
	}

간단한 예제지만 Flux, Mono 둘 다 접한 적이 없어서 좀 더 공부해봐야 할 것 같다