매일 매일, 차곡 차곡 쌓기



완벽하지 않은 것을 두려워 말며,
완성도를 높히는데 집중하자.

Spring/Webflux

Multicasting a Flux to several Subscribers

blockbuddy93 2024. 3. 5. 17:07

publish

구독 시점에 즉시 데이터를 Emit 하지 않고, connect()를 호출하는 시점에 데이터를 emit한다.

Hot Sequence로 변환되기 때문에 구독 시점 이후에 emit된 데이터만 전달 받을 수 있다.

 

autoConnect

파라미터로 지정한 숫자만큼의 구독이 발생하는 시점에 Upstream 소스에 자동으로 연결된다.

즉, publish() 처럼 connect()를 직접 호출할 필요가 없다.

 

refCount

파라미터로 지정하는 숫자만큼의 구독이 발생하는 시점에 Upstream 소스에 자동으로 연결된다.

파라미터로 입력한 숫자 만큼의 구독이 취소되거나 Upstream 데이터 emit이 종료되면 연결이 해제된다.

 

replay

구독 시점에 즉시 데이터를 emit 하지 않고, connet()를 호출하는 시점에 데이터를 emit한다.

구독 시점 이전에 emit 된 데이터를 다시 전달 받을 수 있다.

 

 

'Spring > Webflux' 카테고리의 다른 글

2. 리액티브 스트림즈  (1) 2024.03.07
1. 리액티브 시스템과 리액티브 프로그래밍  (1) 2024.03.06
Splitting a Flux  (0) 2024.03.05
Handling errors  (0) 2024.03.05
Peeking into a sequence  (0) 2024.03.04