Chapter 09 | Sinks

9.1 Sinks란?

• Publisher와 Subscriber의 기능을 모두 지닌 Processor의 향상된 기능 제공
  • Sinks는 Reactor 3.4.0부터 지원
  • Processor API는 Reactor 3.5.0부터 제거 예정
• Signal을 프로그래밍 방식으로 푸시할 수 있는 구조
• 멀티스레드 방식으로 Signal을 전송해도 스레드 안전성을 보장함 (Example9_2)

9.2 Sinks 종류 및 특징 

• Sinks.One : 한 건의 데이터를 프로그래밍 방식으로 emit (Example9_4)
  • Mono 방식으로 Subscriber가 데이터를 소비할 수 있도록 함
    • asMono() 메서드를 사용하여 Mono 객체로 변환
• Sinks.Many : 여러 건의 데이터를 프로그래밍 방식으로 emit
  • Flux 방식으로 Subscriber가 데이터를 소비할 수 있도록 함
    • asFlux() 메서드를 사용하여 Flux 객체로 변환
  • UnicastSpec : 단 하나의 Subscriber (Example9_8)
  • MulticastSpec : 하나 이상의 Subscriber (Example9_9)
  • MulticastReplaySpec : emit된 데이터 중에서 특정 시점으로 되돌린 데이터부터 emit (Example9_10)