# Backpressure

rolroralra

Backpressure란? > Publisher가 끊임없이 emit하는 무수히 많은 데이터를 적절하게 제어하여 데이터 처리에 과부하가 걸리지 않도록 제어하는 데이터 처리 방식 > Reactor에서의 Backpressure 처리 방식 1. 데이터 개수 제어 > Subscriber가 적절히 처리할 수 있는 수준의 데이터 개수를 Publisher에게 요청하는 방식 > BaseSubscriber 객체 hookOnSubscrbie hookOnNext 2. Backpressure 전략 사용 | 종류 | 설명 | | --- | --- | | IGNORE 전략 | Backpressure를 적용하지 않는다. | | ERROR 전략 | Downstream으로 전달할 데이터가 버퍼에 가득 찰 경우, Exception을 발생시키는 전략 | | DROP 전략 | Downstream으로 전달할 데이터가 버퍼에 가득 찰 경우, 버퍼 밖에서 대기하는

judekim

몸상태 안 좋은지 24일째 - 아내도 입안이 다 헐었다고.. 재택근무 오전 DailyScrum 코드 리뷰 요청 TimeBuildService, SortBuildService 코드 리뷰 오후 반차 유료 정책 관련 미팅 Sort & Filter 개발 오늘의 이슈 Sort 및 Filter 처리를 위한 구조화 작업 유료화 관련 정책 - 과거의 실패를 교훈삼아 미리 고민하지 말자. Test Code 가 깨지는지를 CI/CD 환경을 통해 자동화 하여 확인할 수 있도록 해야 한다. 오후 반차가 예정되어 있긴했지만, 오후에 미팅도 잡혀 있어서 점심을 약간 길게 갔다온 수준으로 오후 반차를 진행했다. 점심 먹으러 나가기전에 코드 리뷰를 갑자기 진행되게 되었는데, 간단히 진행할 것이라 생각한 것이 40여분가량 걸렸다. TimeBuild 및 SortBuild 관련해서 간단히 설명을 진행

haero_kim

🔔 앞으로의 Reactive X 시리즈는 RxJava, RxKotlin 기준으로 작성됩니다 공식 문서를 참고하여 작성된 포스팅입니다. Backpressure 전략이 필요한 이유 지난 포스팅에서 Observable 데이터 스트림에서 발생할 수 있는 '배압 현상' 이라는 것에 대해 알아보았고, 이를 제어할 수 있는 데이터 스트림인 Flowable 에 대해서도 알아보았다. 그러나, Flowable 에서도 이 배압 현상을 제어하지 못하여 오류 (MissingBackpressureException)