Spring/Webflux

Filtering a sequence

blockbuddy93 2024. 3. 4. 16:50

filter

Upstream에서 emite된 데이터 중에서 조건에 일치하는 데이터만 Downstream으로 emit한다.

fileter operator의 파라미터로 입력받은 Predicate의 return 값이 true인 데이터만 Downstream으로 emit한다.

 

skip

Upstream 에서 emit 된 데이터 중에서 파라미터로 입력 받은 숫자만큼 건너뛴 후, 나머지 데이터를 Downstream으로 emit한다.

파라미터로 입력받은 시간내에 emit된 데이터를 건너뛴 후, 나머지 데이터를 emit한다.

 

take

Upstream에서 emit되는 데이터 중 파라미터로 입력받은 숫자만큼만, Downstream 으로 emit한다.

Upstream에서 emit되는 데이터 중에서 파라미터로 입력받은 시간내에 emit된 데이터만 downstream으로 emit한다.

 

next

Upstream 에서 emit되는 데이터 중에서 첫번째 데이터만 Downstream으로 emit한다.

Upstream 에서 emit되는 데이턱라 empty라면 Downstream으로 empty Mono를 emit한다.