배압 전략 중에서 DROP 전략과 관련해서 질문 있습니다.

Question

안녕하세요, 강의 진짜 재밌게 보고 있는 수강생입니다 ^^.

Observable과 Flowable에 대한 이해

강의를 보다 조금 애매한 부분이 생겨서 질문드릴게 있습니다.

질문1.

제가 처음에 인지했던 DROP전략은 27:54 에 나오는 대로

"버퍼가 비워지는 시점에 Drop 되지 않은 데이터"가 버퍼에 담긴다는 걸로 인식 했습니다.

그런데 강의 32:56 쯤에 "소비자 쪽에서 데이터의 처리가 끝나지 않으면 생산자 쪽에서 통지한 데이터는 DROP이 된다"라고 알려주십니다.

처음에는 "버퍼가 비워지기 전까지"가 DROP의 조건이였는데, 그 이후에 들은 건 "소비자가 데이터 처리를 계속 하고 있는 상태일 때"가 DROP 조건으로 바뀌는 거 같은데... 정확히 어떤게 맞는 건가요?

질문2.

29:04 의 배압전략(DROP 전략) 그림에서는 버퍼의 크기가 그림으로 보였는데, 그 이후 코드를 보여주실 때(29:14)는 그런 버퍼의 크기를 지정하는 부분이 보이지 않습니다.

버퍼의 크기가 어떻게 지정된 건가요? 그리고 현재 코드 상에서는 버퍼의 크기가 어떻게 되나요?

Answer

안녕하세요? ^^

좋은 포인트를 지적해주셔서 너무 감사드립니다.

먼저 질문하신 부분 답변부터 먼저 드리자면,

질문1.

제가 처음에 인지했던 DROP전략은 27:54 에 나오는 대로

"버퍼가 비워지는 시점에 Drop 되지 않은 데이터"가 버퍼에 담긴다는 걸로 인식 했습니다.

...
...
처음에는 "버퍼가 비워지기 전까지"가 DROP의 조건이였는데, 그 이후에 들은 건 "소비자가 데이터 처리를 계속 하고 있는 상태일 때"가 DROP 조건으로 바뀌는 거 같은데... 정확히 어떤게 맞는 건가요?

--> 질문자님이 생각하신대로 "버퍼가 비워지기 전까지"가 DROP의 조건이 맞습니다.
아마도 "소비자가 데이터 처리를 계속 하고 있는 상태일 때" 이 부분은 "소비자가 데이터 처리를 계속 하고 있는 상태일 때, 그로 인해 버퍼가 가득 찬 상태라면 버퍼가 비워지 전까지..." 라는 표현이 생략되었다고 보시면 되겠네요. ㅡ,.ㅡㅋ

저도 사람이다보니 100퍼센트 완벽하게 수강생분들이 이해할 수 있도록 강의를 만들면 좋았을텐데 때때로 놓치게 되는 부분이 있네요. 아무튼 혼란을 드려서 죄송합니다 ㅡ.ㅡ

질문2.

29:04 의 배압전략(DROP 전략) 그림에서는 버퍼의 크기가 그림으로 보였는데, 그 이후 코드를 보여주실 때(29:14)는 그런 버퍼의 크기를 지정하는 부분이 보이지 않습니다.

버퍼의 크기가 어떻게 지정된 건가요? 그리고 현재 코드 상에서는 버퍼의 크기가 어떻게 되나요?

-->

[그림 1-1] Flowable API Docs

[그림 1-1] Flowable API Docs를 보시면 디폴트 버퍼 사이즈가 128인것을 알 수 있습니다.

[그림 1-2] Scheduler를 통한 버퍼 사이즈 설정

예제 코드에서는 수강생분들의 이해를 돕기 위해 observOn() Operator를 통해 버퍼 사이즈를 1로 지정했습니다.

질문하신부분에 대한 답변이 되셨을까요? ^^

또 질문이나 의견 필요하시면 언제든지 편하게 남겨주세요.

감사합니다!

식빵

배압 전략 중에서 DROP 전략과 관련해서 질문 있습니다.

이 글과 비슷한 Q&A

cold/hot publisher 예제 코드와 관련해 질문 드립니다.

[질문] cascading operator 설명하실 때

_get 함수 부분이 너무 이해가 안갑니다 ㅠ

초급자 질문