[Project Reactor] Operator 정리

[dkdud9261]

empty()

• 데이터를 emit하지 않고 onComplete signal을 전송한다.
• 주로 어떤 특정 작업을 통해 데이터를 전달 받을 필요는 없지만, 작업이 끝났음을 알리고 이에 따른 후처리를 하고 싶을 때 사용할 수 있다.

[dkdud9261]

concatWith()

• 호출하는 publisher와 파라미터로 전달되는 publisher가 각각 emit 하는 데이터들을 하나로 연결해서 새로운 publisher의 데이터 소스로 만들어준다.
• 데이터 자체를 이어 붙여서 하나의 데이터를 emit 하는 게 아니라 emit할 데이터를 하나로 줄 세워서 하나의 데이터 소스를 만든 후에 차례차례 데이터를 emit한다.
• Flux 반환

+) concat() 은 파라미터에 2개 이상의 publisher를 전달해 원하는 만큼의 데이터 소스를 연결할 수 있다. => Flux 반환

[dkdud9261]

collectList()

• upstream publisher에서 emit 하는 데이터를 모아서 List의 원소로 포함시킨 새로운 데이터 소스를 만들어준다.
• Flux<T> -> Mono<List<T>>