Choi hwan

저도 이거에 대해서 많은 고민이 있었는데 제가 찾아낸 해답은 아래와 같습니다.먼저 질문 주신 부분의 코드에서는 에러가 발생한 상황이 맞습니다. 그런데 왜 로그에서 에러가 보이지 않는가하면 아직 에러가 로깅이 출력되지 못한 상황으로 보여집니다.아래의 TImeUitls.sleep(5000L) 을 늘리게되면 제가 첨부한 사진처럼 OnNext() 가 전부 출력된 이후에 error 로그가 찍히게 됩니다.<img src="https://cdn.inflearn.com/public/files/posts/95358e99-139e-4e99-bb36-39f7b08ba5c6/f58bffc5-f781-4ab5-ac2d-f677dd797a9e.webp" media-type="img" alt="스크린샷 2025-05-26 오후 9.04.23.png.webp" title="스크린샷 2025-05-26 오후 9.04.23.png.webp" width="324" height="68">다른 쓰레드에서 동작하니 중간에 발생하고 로그를 적어야하는거아니냐? 라는 의문이 드실수도 있는데 GPT를 통한 답변입니다.<blockquote>예외는 <code>parallel-2</code> (emit 쪽) 스레드에서 발생했지만, <code>subscribe()</code>에 등록된 <code>onError</code> 콜백은 <code>parallel-1</code> (consume 쪽) 워커에서 실행되는 것.</blockquote>즉:<ul><li><code>onBackpressureError()</code> → queue.offer() 실패 → 예외 발생 ← 이건 emit 쪽 (parallel-2)</li><li>이 예외는 downstream으로 전파됨</li><li>리액터는 전파된 예외를 <code>subscribe(onNext, onError)</code>에서 처리함</li><li>subscribe에서 실행되는 <code>onError</code>는 <code>publishOn()</code> 이후이므로 consume 워커 (<code>parallel-1</code>)에서 실행</li></ul>라고 하네요. 저도 공부하면서 궁금했던 내용이였는데 비슷한 질문인것 같아서 답변남깁니다.

Choi hwan

Posts