Reference Reference

다수의 Subscriber에게 Flux를 멀티캐스팅(Multicasting) 하기 위한 Operator

• 다수의 Subscriber에게 Flux를 멀티캐스팅(Multicasting) 하기 위한 Operator

  Spring Reactive Web Application/Project Reactor 2023. 8. 10. 22:00

  Subscriber가 구독을 하면 Upstream에서 emit된 데이터가 구독 중인 모든 Subscriber에게 멀티캐스팅(Multicasting)되는데, 이를 가능하게 해주는 Operator들은 Cold Sequence를 Hot Sequence로 동작하게 하는 특징이 있습니다. publish publish() Operator는 구독을 하더라도 구독 시점에 즉시 데이터를 emit 하지 않고, connect()를 호출하는 시점에 데이터를 emit 합니다. 그리고 Hot Sequence로 변환되기 때문에 구독 시점 이후에 emit된 데이터만 전달받을 수 있습니다. import lombok.extern.slf4j.Slf4j; import reactor.core.publisher.ConnectableFlux; ..

  Read More