Reactor에서 ConnectableFlux로 Hot 스트림 만들고 publishOn으로 스레드 제어하기

원문은 과일바구니 예제를 통해 하나의 스트림에서 여러 연산(distinct, count 등)을 수행할 때의 효율성 문제를 다룬다. 초기에는 각 연산에 subscribeOn(Schedulers.parallel())을 적용했으나, 이는 소스 스트림을 중복 순회하게 만들고 데몬스레드 종료 문제를 유발할 수 있다. 이를 해결하기 위해 Flux.fromIterable의 결과를 publish().autoConnect(2)를 통해 ConnectableFlux(Hot)로 변환하여 소스 스트림을 한 번만 순회하도록 한다. 이후 분기된 각 연산 스트림에서는 subscribeOn이 아닌 publishOn을 사용하여 해당 연산자 이후의 스레드만 전환함으로써, 소스 구독은 유지하면서 병렬 처리가 가능하도록 스레드 컨텍스트를 제어하는 방법을 설명한다.