Flux 를 생성하는 가장 간단한 방법은, Flux 클래스에서 제공하는 팩토리 메서드 를 사용하는 것이다. 대표적으로 아래와 같은 팩토리 메서드를 제공한다.

• just
• range
• fromArray, fromIterable, fromStream
• empty

Flux 는 subscribe 가 실행하기 전까지는 어떤 일도 발생하지 않는다

Publisher (발행자)는 구독이 되었을 경우에만 데이터를 Subscriber(구독자)에게 전달한다.

Subscriber(구독자)가 Publisher 에 구독을 하는 과정은, Publisher(발행자)에 정의된 subscribe() 메서드를 사용한다.

이때, 매개변수로 Consumer 함수를 전달할 수 있는데, Consumer 함수는 데이터 전달을 해서 Subscriber의 onNext 이벤트가 발생을 했을때 실행되는 함수이다.

이벤트 순서

onSubscribe --> request --> onNext --> onNext --> onComplete

range 메서드는 int 범위를 지정하여 순차적인 데이터를 생성해주는 Flux 의 메서드이다.

이벤트 순서

onSubscribe --> request --> onNext --> onComplete

fromArray, fromIterable, fromStream 메서드를 사용하면 Array, Iterable, Streams 를 사용해서 Flux 를 생성할 수 있다.

empty 메서드를 사용하면 아무값도 전달하지 않는, Empty Flux를 만들 수 있다.

Flux 와 Mono 는 subscribe() 가 실행하기 전까지는 그 어떤 데이터도 전달하지 않는다

• just
• empty

• doOnSubscribe

• doOnRequest

• doOnNext

• doOnError

• doOnComplete

• doOnCancle

• doOnEach

Flux 는 Publisher 의 구현체이다.

일반적인 Reactive Streams 에서의 Publisher 는 subscribe 를 실행할 때 subscriber 를 등록해준다.

Flux 에서 제공하는 팩토리 메서드는 subscriber 를 등록해주는 메서드도 있는 반면에, subscriber 를 매개변수로 등록하지 않는 함수도 존재한다.

subscriber 가 필요없어서가 아니라, 내부 로직에서 자동으로 subscriber 를 만들어 준다.

개발자가 따로 subscriber 를 등록하지 않아도 된다.

Project Reactor의 핵심 패키지 중 하나인 reactor.core.scheduler에는 Schedulers 라는 추상 클래스가 존재한다. 이 Schedulers는 Scheduler 인터페이스의 팩토리 클래스이고, publishOn과 subscribeOn 을 위한 여러가지 팩토리 메서드를 제공한다.

팩토리 메서드는 대표적으로 아래와 같다.

parallel(): ExecutorService기반으로 단일 스레드 고정 크기(Fixed) 스레드 풀을 사용하여 병렬 작업에 적합함. single(): Runnable을 사용하여 지연이 적은 일회성 작업에 최적화 elastic(): 스레드 갯수는 무한정으로 증가할 수 있고 수행시간이 오래걸리는 블로킹 작업에 대한 대안으로 사용할 수 있게 최적화 되어있다. boundedElastic(): 스레드 갯수가 정해져있고 elastic과 동일하게 수행시간이 오래걸리는 블로킹 작업에 대한 대안으로 사용할 수 있게 최적화 되어있다. immediate(): 호출자의 스레드를 즉시 실행한다. fromExecutorService(ExecutorService) : 새로운 Excutors 인스턴스를 생성한다.

출처: https://devsh.tistory.com/entry/Schedulers-정리 [날샘 코딩]