delayElements()
-
Sequence의 동작 시간 측정을 위한 OperatorSpring Reactive Web Application/Project Reactor 2023. 8. 8. 21:00
Reactor Sequence의 동작 시간을 제어하는 Operator에는 delayElements(), interval(), timeout() 등이 있습니다. 이외 동작 시간 자체를 측정하는 elapsed Operator가 존재합니다. elapsed elapsed() Operator는 emit된 데이터 사이의 경과 시간을 측정해서 Tuple 형태로 Downstream에 emit 합니다. emit 되는 첫 번째 데이터는 onSubscribe Signal과 첫 번째 데이터 사이를 기준으로 시간을 측정합니다. 측정된 시간의 단위는 milliseconds 입니다. 다음은 delayElements() Operator를 사용하여 1초에 한 번씩 데이터가 emit 되고, Subscriber는 emit 되는 데이터 사..
-
Cold Sequence와 Hot SequenceSpring Reactive Web Application/Project Reactor 2023. 7. 23. 09:00
Cold Sequence Subscriber의 구독 시점이 달라도 구독을 할 때마다 Publisher가 데이터를 emit하는 과정을 처음부터 다시 시작하는 데이터 흐름을 Cold Sequence라고 부릅니다. 그리고 이 Cold Sequence 흐름으로 동작하는 Publisher를 Cold Publisher라고 합니다. import lombok.extern.slf4j.Slf4j; import reactor.core.publisher.Flux; import java.util.Arrays; /** * Cold Sequence 예제 */ @Slf4j public class Example7_1 { public static void main(String[] args) throws InterruptedExcepti..